3.使用 Statement 接口实现增，删，改操作（本人觉得可能再也不会用了，不安全）

package com.java1234.jdbc.model;

/**
* 图书模型
* @author caofeng
*
*/
public class Book {

private int id;
private String bookName;
private float price;
private String author;
private int bookTypeId;

public Book(int id, String bookName, float price, String author,
int bookTypeId) {
super();
this.id = id;
this.bookName = bookName;
this.price = price;
this.author = author;
this.bookTypeId = bookTypeId;
}
public Book(String bookName, float price, String author, int bookTypeId) {
super();
this.bookName = bookName;
this.price = price;
this.author = author;
this.bookTypeId = bookTypeId;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getBookName() {
return bookName;
}
public void setBookName(String bookName) {
this.bookName = bookName;
}
public float getPrice() {
return price;
}
public void setPrice(float price) {
this.price = price;
}
public String getAuthor() {
return author;
}
public void setAuthor(String author) {
this.author = author;
}
public int getBookTypeId() {
return bookTypeId;
}
public void setBookTypeId(int bookTypeId) {
this.bookTypeId = bookTypeId;
}

}

package com.java1234.jdbc.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class DbUtil {

// 数据库地址
private static String dbUrl="jdbc:mysql://localhost:3306/db_book";
// 用户名
private static String dbUserName="root";
// 密码
private static String dbPassword="123456";
// 驱动名称
private static String jdbcName="com.mysql.jdbc.Driver";

/**
* 获取数据库连接
* @return
* @throws Exception
*/
public Connection getCon()throws Exception{
Class.forName(jdbcName);
Connection con=DriverManager.getConnection(dbUrl, dbUserName, dbPassword);
return con;
}

/**
* 关闭连接
* @param con
* @throws Exception
*/
public void close(Statement stmt,Connection con)throws Exception{
if(stmt!=null){
stmt.close();
if(con!=null){
con.close();
}
}

}
}

package com.java1234.jdbc.chap03.sec02;

import java.sql.Connection;
import java.sql.Statement;

import com.java1234.jdbc.model.Book;
import com.java1234.jdbc.util.DbUtil;

public class Demo2 {

private static DbUtil dbUtil=new DbUtil();

/**
* 添加图书2
* @param book
* @return
* @throws Exception
*/
private static int addBook2(Book book)throws Exception{
Connection con=dbUtil.getCon();  // 获取连接
String sql="insert into t_book values(null,'"+book.getBookName()+"',"+book.getPrice()+",'"+book.getAuthor()+"',"+book.getBookTypeId()+")";
Statement stmt=con.createStatement(); // 创建Statement
int result=stmt.executeUpdate(sql);
dbUtil.close(stmt, con);  // 关闭Statement和连接
return result;
}

/**
* 添加图书
* @param bookName
* @param price
* @param author
* @param bookTypeId
* @return
* @throws Exception
*/
private static int addBook(String bookName,float price,String author,int bookTypeId)throws Exception{
Connection con=dbUtil.getCon();  // 获取连接
String sql="insert into t_book values(null,'"+bookName+"',"+price+",'"+author+"',"+bookTypeId+")";
Statement stmt=con.createStatement(); // 创建Statement
int result=stmt.executeUpdate(sql);
dbUtil.close(stmt, con);  // 关闭Statement和连接
return result;
}

public static void main(String[] args) throws Exception{
/*int result=addBook("Java牛牛", 121, "牛哥", 1);
if(result==1){
System.out.println("添加成功！");
}else{
System.out.println("添加失败！");
}*/
// 多行注释  ctrl+shift+/
Book book=new Book("Java牛牛2", 1212, "牛哥2", 2);
int result=addBook2(book);
if(result==1){
System.out.println("添加成功！");
}else{
System.out.println("添加失败！");
}
}
}

package com.java1234.jdbc.chap03.sec03;

import java.sql.Connection;
import java.sql.Statement;

import com.java1234.jdbc.model.Book;
import com.java1234.jdbc.util.DbUtil;

public class Demo1 {

private static DbUtil dbUtil = new DbUtil();

/**
* 更新图书
* @param book
* @return
* @throws Exception
*/
private static int updateBook(Book book) throws Exception {
Connection con = dbUtil.getCon(); // 获取连接
String sql = "update t_book set bookName='" + book.getBookName()
+ "',price=" + book.getPrice() + ",author='" + book.getAuthor()
+ "',bookTypeId=" + book.getBookTypeId() + " where id="
+ book.getId();  // ctrl+a 全选  ctrl+shift+F 格式化代码
Statement stmt = con.createStatement(); // 创建Statement
int result = stmt.executeUpdate(sql);
dbUtil.close(stmt, con); // 关闭Statement和连接
return result;
}

public static void main(String[] args) throws Exception{
Book book=new Book(3,"Java牛牛2222", 121, "牛哥222", 1);
int result=updateBook(book);
if(result==1){
System.out.println("更新成功！");
}else{
System.out.println("更新败！");
}

}
}

package com.java1234.jdbc.chap03.sec04;

import java.sql.Connection;
import java.sql.Statement;

import com.java1234.jdbc.util.DbUtil;

public class Demo1 {

private static DbUtil dbUtil=new DbUtil();

/**
* 删除图书
* @param id
* @return
* @throws Exception
*/
private static int deleteBook(int id)throws Exception{
Connection con = dbUtil.getCon(); // 获取连接
String sql ="delete from t_book where id="+id;
Statement stmt = con.createStatement(); // 创建Statement
int result = stmt.executeUpdate(sql);
dbUtil.close(stmt, con); // 关闭Statement和连接
return result;
}

public static void main(String[] args) throws Exception{
int result=deleteBook(3);
if(result==1){
System.out.println("删除成功！");
}else{
System.out.println("删除失败！");
}
}
}