JDBC 使用步骤(笔记)

1.注册驱动

Class.forName("com.mysql.jdbc.Driver");

2. 建立连接

// 建立连接  参数1：协议+访问的数据库名   参数2：用户名  参数3：数据库密码  
             conn=(Connection) DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "123456");

3.创建Statement

// 创建statement  ，跟数据库打交道，一定需要这个对象
             statement= conn.createStatement();

4. 执行sql 语句 得到ResultSet

// 执行sql 
            String sql="select * from  t_stu";
            
             rSet=statement.executeQuery(sql);
    

4. 遍历得到结果

//遍历查询每一条数据
            while (rSet.next()) {
                int id=rSet.getInt("id");
                String name=rSet.getString("name");
                int age=rSet.getInt("age");
                System.out.println("id="+id+"name="+name+"age="+age);
            }

5.释放资源

       rSet.close();
       connection.close();
       statement.close();

6.jdbc工具类构建

6.1 防止驱动二次注册

Class.forName("com.mysql.jdbc.Driver");

6.2 使用properties配置文件

1.先在src目录下生成一个jdbc.properties 文件 内容如下:

driverClass=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost/test
name=root
password=123456

2. 在工具类中 使用静态代码块 读取属性

static {

        try {
            // 创建一个属性配置对象
            Properties properties = new Properties();

             InputStream is = new FileInputStream("jdbc.properties");//对应文件位于项目的跟目录
            //使用类加载
            //InputStream is=JDBCUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");//对应文件位于src目录下
            // 导入输入流
            properties.load(is);
            // 读取属性
            driverClass = properties.getProperty("driverClass");
            url = properties.getProperty("url");
            name = properties.getProperty("name");
            password = properties.getProperty("password");
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

7.数据库CRUD

• insert

INSERT INTO  t_stu (NAME,age)VALUES ("张三",20); 

// 连接对象
            connection = JDBCUtil.getConn();
            // 根据连接对象 得到Statement
            statement = connection.createStatement();

            // 执行添加
            String sql = "insert into t_stu value(null,'aobama',59)";
            //影响的行数 如果result大于0 表示添加成功
            int result = statement.executeUpdate(sql);
            if (result>0) {
                System.out.println("添加成功");
            }else {
                System.out.println("添加失败");
            }

• delete

 DELETE FROM t_stu WHERE id=3;

// 连接对象
            connection = JDBCUtil.getConn();
            // 根据连接对象 得到Statement
            statement = connection.createStatement();

            // 执行添加
            String sql = "delete  from t_stu where name='aobama' ";
            //影响的行数 如果result大于0 表示添加成功
            int result = statement.executeUpdate(sql);
            if (result>0) {
                System.out.println("删除成功");
            }else {
                System.out.println("删除失败");
            }

• query

SELECT *FROM t_stu


// 连接对象
            connection = JDBCUtil.getConn();
            // 根据连接对象 得到Statement
            statement = connection.createStatement();
            // 执行sql语句 返回ResultSet
            String sql = "select * from t_stu";
            rSet = statement.executeQuery(sql);
            // 遍历结果集
            while (rSet.next()) {
                String name = rSet.getString("name");
                int age = rSet.getInt("age");

                System.out.println("name====" + name + "----age===" + age);

            }

• update

UPDATE t_stu SET age=38 WHERE id=1;