JDBC的编程六步

我就是我 2022-11-26 01:57 157阅读 0赞

**JDBC的编程六步：**

1、JDBC编程六步：

（1）**注册驱动**：DriverManager.registerDriver(new com.mysql.jdbc.Driver());

（2）**获取连接**：Connection conn = DriverManager.getConnection(url, user, password);

（3）**获取数据库操作对象**：Statement stmt = conn.createStatement();

（4）**执行sql语句**：int affectLine = stmt.executeUpdate(sql);

（5）**处理查询结果集**：下面再说。

（6）**释放资源**：stmt.close(), conn.close();

记住几个关键类：Driver，DriverManager，Connection，Statement。

**JDBC中执行的sql语句中不需要写分号。**

测试代码：

package jdbc_six_steps;
    
    import java.sql.*;
    
    public class Test01 { 
        public static void main(String[] args) { 
    
            Connection conn = null;
            Statement stmt = null;
    
            try { 
                // 1、注册驱动
                Driver driver = new com.mysql.jdbc.Driver();  // 多态
                DriverManager.registerDriver(driver);
    
                // 2、获取连接
                /* url：统一资源定位符（网络中某个资源的绝对路径） https//:www.baidu.com/ 这就是url url包括哪几部分：协议 + IP + 端口 + 资源名 例如百度的url为：https://182.61.200.7:80/index.html; https//：通信协议 182.61.200.7：百度服务器的IP地址 80：某个软件的端口号 index.html：资源 mysql的url为：jdbc:mysql://127.0.0.1:3306/study_test; jdbc:mysql:// 连接mysql的通信协议 127.0.0.1 IP地址 3306 端口号 study_test 具体要连接的数据库实例名称 其中的127.0.0.1也可以写成localhost，都是本机的IP地址 Oracle的url：jdbc:oracle:thin:@localhost:1521:数据库名称; */
                String url = "jdbc:mysql://127.0.0.1:3306/study_test";
                String user = "root";
                String password = "666666";
                conn = DriverManager.getConnection(url, user, password);
    
                // 3、获取数据库操作对象
                stmt = conn.createStatement();
    
                // 4、执行sql语句
                String sql = "insert into dept(deptno, dname, loc) values(50, '财务部', '北京')";
                /* executeUpdate(String sql)方法是专门执行DML（insert，delete，update）语句的。 返回结果是这条DML语句影响数据库记录的行数，例如插入一条记录，如果成功，将会影响一行数据。 */
                int affectLine = stmt.executeUpdate(sql);
                System.out.println(affectLine == 1 ? "插入成功" : "插入失败");
    
                // 5、处理查询结果集
    
            } catch (SQLException throwables) { 
                throwables.printStackTrace();
            } finally { 
                // 6、释放资源
                // 要按照从小到大的顺序依次关闭资源，并且分别使用try..catch语句
                if (stmt != null) { 
                    try { 
                        stmt.close();  // 先关闭数据库操作对象
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
                if (conn != null) { 
                    try { 
                        conn.close();  // 再关闭连接对象
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
            }
    
        }
    }

--------------------

**2、JDBC完成delete操作：**

测试代码：

package jdbc_six_steps;
    
    import java.sql.*;
    
    
    public class Test02 { 
        public static void main(String[] args) { 
    
            Connection conn = null;
            Statement stmt = null;
    
            try { 
                // 1、注册驱动
                DriverManager.registerDriver(new com.mysql.jdbc.Driver());
    
                // 2、获取连接
                conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/study_test", "root", "666666");
    
                // 3、获取数据库操作对象
                stmt = conn.createStatement();
    
                // 4、执行sql语句
                String sql = "delete from dept where deptno = 50";
                int affectLine = stmt.executeUpdate(sql);
                System.out.println(affectLine == 1 ? "删除成功" : "删除失败");
    
                // 5、处理查询结果集，因为执行的是DML语句，不需要处理查询结果集
    
            } catch (SQLException throwables) { 
                throwables.printStackTrace();
            } finally { 
                // 6、释放资源
                if (stmt != null) { 
                    try { 
                        stmt.close();
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
                if (conn != null) { 
                    try { 
                        conn.close();
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
            }
    
        }
    }

--------------------

**3、注册驱动的另一种写法：**  
反射机制类加载方式，这才是最常用的。

我们通过打开mysql驱动的Driver类，查看它的源码：  
发现只有一个无参数构造方法，还有一个静态代码块。

静态代码块内容如下：

static { 
        try { 
             DriverManager.registerDriver(new Driver());
        } catch (SQLException var1) { 
             throw new RuntimeException("Can't register driver!");
        }
    }

只要执行这段静态代码块，就可以完成注册驱动。

怎么执行一个类的静态代码块？  
**反射机制类加载**：Class.forName(“com.mysql.jdbc.Driver”);

因为Class.forName(“com.mysql.jdbc.Driver”)中的参数可以写到配置文件中。  
代码不需要改动，就可以连接不同品牌的数据库。

测试代码：

package jdbc_six_steps;
    
    import java.sql.*;
    
    public class Test03 { 
        public static void main(String[] args) throws Exception { 
    
            // 1、注册驱动
            Class.forName("com.mysql.jdbc.Driver");
    
            // 2、获取连接
            String url = "jdbc:mysql://localhost:3306/study_test";
            String user = "root";
            String password = "666666";
            Connection conn = DriverManager.getConnection(url, user, password);
            System.out.println(conn);  // com.mysql.jdbc.JDBC4Connection@5ba23b66
    
            // 6、释放资源
            conn.close();
        }
    }

--------------------

**4、将连接数据库的参数信息填写到配置文件中，使用代码动态读取配置文件里的信息。**

我们新建一个配置文件jdbcTest04.properties，内容如下：  
Driver=com.mysql.jdbc.Driver  
url=jdbc:mysql://127.0.0.1:3306/study\_test  
user=root  
password=666666  
在src文件下，建立一个目录dir，放入其中。

测试代码：

package jdbc_six_steps;
    
    import java.sql.*;
    import java.util.ResourceBundle;
    
    
    public class Test04 { 
        public static void main(String[] args) { 
    
            // 资源绑定器，读取配置文件信息
            ResourceBundle bundle = ResourceBundle.getBundle("dir/jdbcTest04");
            String driver = bundle.getString("Driver");
            String url = bundle.getString("url");
            String user = bundle.getString("user");
            String password = bundle.getString("password");
    
            Connection conn = null;
            Statement stmt = null;
    
            try { 
                // 1、注册驱动
                Class.forName(driver);
    
                // 2、获取连接
                conn = DriverManager.getConnection(url, user, password);
    
                // 3、获取数据库操作对象
                stmt = conn.createStatement();
    
                // 4、执行sql语句
                String sql = "delete from dept where deptno = 50";
                int affectLine = stmt.executeUpdate(sql);
                System.out.println(affectLine == 1 ? "删除成功" : "删除失败");
    
                // 5、处理查询结果集
    
            } catch (ClassNotFoundException | SQLException e) { 
                e.printStackTrace();
            } finally { 
                if (stmt != null) { 
                    try { 
                        stmt.close();
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
                if (conn != null) { 
                    try { 
                        conn.close();
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
            }
    
        }
    }

--------------------

**5、处理查询结果集**

注意：执行DML(insert, delete, update)语句用executeUpdate(sql)方法;  
int affectLine = stmt.executeUpdate(sql);

执行DQL(select)语句用executeQuery(sql)方法;  
ResultSet result = conn.executeQuery(sql);

ResultSet结果集，也就是在数据库中执行select语句后，得到的一张临时表。

可以用循环遍历，result.next()方法判断是否有下一行数据，  
result.getString(参数), getInt(参数), getDouble(参数)等获取列中的数据。

参数可以是下标，JDBC中的下标从1开始（不建议使用下标方式获取）。  
参数也可以是查询结果集的的列明，注意不是表中字段的名字，是结果临时表的列名。

重命名后的列名，或者原字段名，这就要看select语句是怎么写的。

**如果有重命名，就必须使用重命名之后的名字。**

测试代码：

package jdbc_six_steps;
    
    import java.sql.*;
    
    public class Test05 { 
        public static void main(String[] args) { 
    
            // 先准备连接数据库的配置信息
            String driver = "com.mysql.jdbc.Driver";
            String url = "jdbc:mysql://127.0.0.1:3306/study_test";
            String user = "root";
            String password = "666666";
    
            Connection conn = null;
            Statement stmt = null;
            ResultSet result = null;
    
            try { 
                // 1、注册驱动
                Class.forName(driver);
    
                // 2、获取连接
                conn = DriverManager.getConnection(url, user, password);
    
                // 3、获取数据库操作对象
                stmt = conn.createStatement();
    
                // 4、执行sql语句
                String sql = "select empno, ename, sal from emp";
                result = stmt.executeQuery(sql);
    
                // 5、处理查询结果集
                while (result.next()) { 
                    /*String empno = result.getString(1); String ename = result.getString(2); String sal = result.getString(3); System.out.println(empno + " " + ename + " " + sal);*/
    
                    /*String empno = result.getString("empno"); String ename = result.getString("ename"); String sal = result.getString("sal"); System.out.println(empno + " " + ename + " " + sal);*/
    
                    // 这种方式才是最常用的，对应数据类型，对应列名
                    // 列名跟数据库表中的字段名无关，而是跟select语句有关，如果列名用了empno as no，那么对应参数就为no。
                    int empno = result.getInt("empno");
                    String ename = result.getString("ename");
                    double sal = result.getDouble("sal");
    
                    //System.out.println(result.getRow()); // 获取此行记录是在临时表中的第几行
                    System.out.println(result.getRow() + ": " + empno + " " + ename + " " + sal);
                }
    
            } catch (SQLException | ClassNotFoundException throwables) { 
                throwables.printStackTrace();
            } finally { 
                // 6、释放资源
                if (result != null) { 
                    try { 
                        result.close();  // 首先，关闭结果集
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
                if (stmt != null) { 
                    try { 
                        stmt.close();  // 然后，关闭数据库操作对象
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
                if (conn != null) { 
                    try { 
                        conn.close();  // 最后，关闭连接
                    } catch (SQLException throwables) { 
                        throwables.printStackTrace();
                    }
                }
            }
    
        }
    
    }

--------------------