JDBC操作数据库之连接数据库

通过JDBC向数据库中添加数据的时候，使用insert语句实现数据的插入，再SQL语句中的参数可以用占位符“？”来替代，然后通过PreparedStatement对象或者Statement对象对其赋值并执行SQL。

下面分别对PreparedStatement接口和Statement接口插入数据方法做代码实现：其中PreparedStatementTest类中是用PreparedStatement接口中的方法来实现数据库数据插入的；StatementTest类中是用Statement接口中的excuteUpdate(sql)方法实现数据库数据插入。

public class Book{
    //编号
    private int id;
    //图书名称
    private String name;
    //价格
    private double price;
    //数量
    private int bookCount;
    //作者
    private String author;
    
    public int getId() {
        return id;
    }
    
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public double getPrice() {
        return price;
    }
    public void setPrice(double price) {
        this.price = price;
    }
    public int getBookCount() {
        return bookCount;
    }
    public void setBookCount(int bookCount) {
        this.bookCount = bookCount;
    }
    public String getAuthor() {
        return author;
    }
    public void setAuthor(String author) {
        this.author = author;
    }
}
/****方法一：通过PreparedStatement接口中的方法插入数据*****/
public class PreparedStatementTest{
        Book book = new Book();
        //加载数据库驱动，注册到驱动管理器
        Class.forName("com.mysql.jdbc.Driver");
        //数据库连接字符串
        String url = "jdbc:mysql://localhost:3306/Test";
        //数据库用户名
        String username = "root";
        //数据库连接密码
        String password = "123";
        //创建Connection连接
        Connection conn = (Connection)DriverManager.getConnection(url,username,password);
        //插入图书信息的SQL语句
        String sql = "insert into bookTable(name,price,bookCount,author) value(?,?,?,?);";
        //获取PreparedStatement
        PreparedStatement ps = conn.prepareStatement(sql);
        //对SQL语句中的第1个参数赋值
        ps.setString(1, book.getName());
        //对SQL语句中的第2个参数赋值
        ps.setDouble(2,book.getPrice());
        //对SQL语句中的第3个参数赋值
        ps.setInt(3, book.getBookCount());
        //对SQL语句中的第4个参数赋值
        ps.setString(4, book.getAuthor());
        //执行更新操作，返回所影响的行数
        int row = ps.executeUpdate();
        //判断是否更新成功
        if(row > 0){
            out.print("添加成功"+row+"条数据");
        }
        //关闭PreparedStatement,释放资源
        ps.close();
        //关闭Connection释放资源
        conn.close();

}

/*方法二：通过Statement接口中的executeUpdate(sql)方法插入数据*/
public class StatementTest{
        Book book = new Book();
        //加载数据库驱动，注册到驱动管理器
        Class.forName("com.mysql.jdbc.Driver");
        //数据库连接字符串
        String url = "jdbc:mysql://localhost:3306/Test";
        //数据库用户名
        String username = "root";
        //数据库连接密码
        String password = "123";
        //创建Connection连接
        Connection conn = (Connection)DriverManager.getConnection(url,username,password);
        //插入图书信息SQL语句
        String sql="insert into bookTable(name,price,bookCount,author) value("+book.getName()+","+book.getPrice()+","+book.getBookCount()+","+book.getAuthor()+")";
        //获取Statement接口对象
        Statement stat = conn.createStatement();
        //调用Statement接口中的excuteUpdate(sql)方法，执行SQL语句插入数据
        stat.executeUpdate(date);

        //关闭Statement接口对象
        if(stat != null){
            stat.close();
        }
        //关闭Connection接口对象
        if(conn != null){
            conn.close();
        }
}

---恢复内容结束---