数据库学习笔记02：statement对象详解、数据库的增删改查四大方法

Jdbc中的statement对象用于向数据库发送SQL语句，想完成对数据库的增删改查，只需要通过这个对象向数据库发送增删改查语句即可。

Statement对象的executeUpdate方法，用于向数据库发送增、删、改的sq|语句， executeUpdate执行完后， 将会返回一个整数(即增删改语句导致了数据库几行数据发生了变化)。

Statement.executeQuery方法用于向数据库发生查询语句，executeQuery方法返回代表查询结果的ResultSet对象。

1.创建db.properties文件
书写内容
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/jdbcstudy?useUnicode=true&characterEncoding=utf8&useSSL=true
username=root
password=163291367sxh
2.创建工具类

package JDBC.statement.utils;

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;

//工具类
public class JdbcUtils {
    private static String driver=null;
    private static String url=null;
    private static String username=null;
    private static String password=null;

    static {
        try {
            InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
            Properties properties = new Properties();
            properties.load(in);

            driver = properties.getProperty("driver");
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");

            //1.加载驱动，驱动只用加载一次
            Class.forName(driver);

        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
        }
    }
    //获取连接
    public static Connection getConnection() throws SQLException{
            return DriverManager.getConnection(url,username,password);
        }

    //释放连接资源
    public static void release(Connection con, Statement st, ResultSet rs) {
            if(rs!=null){

                try {
                    rs.close();
                }catch (SQLException e){
                    e.printStackTrace();
                }

            }
            if (st!=null){
                try {
                    st.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }

            }
            if(con!=null){
                try {
                    con.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }

}

增加——Insert
代码：
注释：代码直接用了我上面创建的工具类，所有这样写了连接以及关闭资源部分

package JDBC.statement;
import JDBC.statement.utils.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class TestInsert {
    public static void main(String[] args) {

        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        try {
            conn=JdbcUtils.getConnection();//获取数据库连接
            st= conn.createStatement();//创建statement,获得SQL的执行对象
            //插入一条信息，插入主键不能重复
            String sql="INSERT INTO users(id,`NAME`,`PASSWORD`,`email`,`birthday`)" +
                    "VALUES(4,'mingren','123456','9999@qq.com','2021-10-7')";

            int i=st.executeUpdate(sql);
            if(i>0){
                System.out.println("插入成功");
            }


        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}

运行结果：成功增加了第四条

删除——delete

将上述代码指令部分替换即可

            String sql="DELETE FROM users WHERe id=4";
            int i=st.executeUpdate(sql);
            if(i>0){
                System.out.println("删除成功");
            }

运行结果：成功删除了第四条

修改——update
指令部分

            //修改一条数据
            String sql="UPDATE users SET `NAME`='libai',`email`='666@qq.com' WHERe id=1";
            int i=st.executeUpdate(sql);
            if(i>0){
                System.out.println("修改成功");
            }

运行结果：成功将第一条的信息进行了修改

查询——query

package JDBC.statement;
import JDBC.statement.utils.JdbcUtils;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class TestSelect {

    public static void main(String[] args) {
        Connection conn=null;
        Statement st=null;
        ResultSet rs=null;
        try {
            conn= JdbcUtils.getConnection();//获取数据库连接
            st= conn.createStatement();//创建statement,获得SQL的执行对象
            //查询
            String sql="select * from users where id=1";
            rs=st.executeQuery(sql);
            while (rs.next()){
                System.out.println(rs.getString("NAME"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            JdbcUtils.release(conn,st,rs);
        }
    }
}