# JDBC JDBC：(Java Database Connectivity) Java数据库连接技术。 ## jar 包 jar 包就是一组类的集合，为什么要用于域名定义包的原因就在于此，一个项目中可以会引用很多的包，如果包中不能唯一标识一个类，在第三方使用的时候就有可能出现不能引用正确类的问题。 **在 Eclipse 中装备 jar 文件** - 在项目目录下新建一个文件夹 lib ，将 jar 文件拷贝到 lib 目录； - 在 build path 菜单中 「libraries」→ 「add jars」关联进项目； ## 使用 JDBC > mysql 的 JDBC 驱动 jar 包引入项目中。 **开发步骤：** 1. 选择数据库：加载数据库驱动 2. 连接数据库 3. 创建数据库查询 4. 获取查询结果 5. 关闭查询和连接 在使用 JDBC 的时候，需要关注的几个问题 - 查询分为操作类（增加、删除、修改）和查询类。 - 要避免重复的创建连接，增加数据库的连接数。 - 注意异常的处理逻辑，保证没有未关闭的无效连接存在。 **完整的 JDBC 操作代码** ~~~ public class Demo1 { public static void main(String[] args) { insert("Tom", "1", "Java96"); } public static void insert(String name, String code, String clazz) { Connection conn = null; PreparedStatement ps = null; String url = "jdbc:mysql://localhost:3306/demo2"; String user = "root"; String password = "123456"; try { // 1. 选择数据库：加载数据库驱动 Class.forName("com.mysql.jdbc.Driver"); // 2. 连接数据库 conn = DriverManager.getConnection(url, user, password); // 3. 创建数据库查询 ps = conn.prepareStatement("INSERT1 INTO demo1(name,code,clazz) VALUES(?,?,?)"); ps.setString(1, name); ps.setString(2, code); ps.setString(3, clazz); // 4. 获取查询结果 int i = ps.executeUpdate(); System.out.println("一共执行了" + i + "条"); } catch (ClassNotFoundException e) { System.out.println("数据库驱动没有找到"); e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } finally { // 5. 关闭查询和连接 try { if (null != ps) { ps.close(); } if (null != conn) { conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } } } ~~~ **考虑了连接创建效率的 JDBC 代码，以及查询的字段处理** ~~~ package com; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; public class Demo2 { public static void main(String[] args) { createConn(); for (int i = 1; i <= 100; i++) { String istr = String.format("%03d", i); exeUpdate("Jack" + istr, String.valueOf(i), "Java96"); } exeQuery("Jack"); closeConn(); } private static Connection conn; /** * 创建连接 */ public static void createConn() { try { conn = null; String url = "jdbc:mysql://localhost:3306/demo2"; String user = "root"; String password = "123456"; // 1. 选择数据库：加载数据库驱动 Class.forName("com.mysql.jdbc.Driver"); // 2. 连接数据库 conn = DriverManager.getConnection(url, user, password); } catch (ClassNotFoundException e) { System.out.println("数据库驱动没有找到"); e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } public static void exeQuery(String name) { PreparedStatement ps = null; try { // 创建数据库查询 ps = conn.prepareStatement("SELECT id,name,code,clazz FROM demo1 WHERE name LIKE ?"); ps.setString(1, name + "%"); // 获取查询结果 ResultSet rs = ps.executeQuery(); // 遍历结果 while (rs.next()) { int id = rs.getInt("id"); String name1 = rs.getString("name"); String code = rs.getString("code"); String clazz = rs.getString("clazz"); System.out.println("id="+id+",name="+name1+",code="+code+",clazz="+clazz+""); } } catch (SQLException e) { e.printStackTrace(); } finally { // 5. 关闭查询 try { if (null != ps) { ps.close(); } } catch (SQLException e) { e.printStackTrace(); } } } public static void exeUpdate(String name, String code, String clazz) { PreparedStatement ps = null; try { // 创建数据库查询 ps = conn.prepareStatement("INSERT INTO demo1(name,code,clazz) VALUES(?,?,?)"); ps.setString(1, name); ps.setString(2, code); ps.setString(3, clazz); // 获取查询结果 int i = ps.executeUpdate(); System.out.println("一共执行了" + i + "条"); } catch (SQLException e) { e.printStackTrace(); } finally { // 5. 关闭查询 try { if (null != ps) { ps.close(); } } catch (SQLException e) { e.printStackTrace(); } } } /** * 关闭连接 */ public static void closeConn() { // 5. 关闭连接 try { if (null != conn) { conn.close(); } } catch (SQLException e) { e.printStackTrace(); } } } ~~~