一、什么是JDBC
JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。
二、JDBC编码步骤
0、前提：拷贝数据库的驱动到构建路径中（classpath）
1、注册驱动
2、获取与数据库的链接
3、创建代表SQL语句的对象
4、执行SQL语句
5、如果是查询语句，需要遍历结果集
6、释放占用的资源
三、代码实现
1、在终端或者navicat中创建一个表：users， 如下图：
2、创建一个名为JdbcDemo1的类，并导入包：mysql-connector-java-5.0.8-bin.jar， JdbcDemo1代码如下：
1 package com.bigshow1949.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.SQLException; 7 import java.sql.Statement; 8 9 /* 10 create table users( 11 id int primary key auto_increment, 12 name varchar(40), 13 password varchar(40), 14 email varchar(60), 15 birthday date 16 )character set utf8 collate utf8_general_ci; 17 18 insert into users(name,password,email,birthday) values('zs','123456','zs@sina.com','1980-12-04'); 19 insert into users(name,password,email,birthday) values('lisi','123456','lisi@sina.com','1981-12-04'); 20 insert into users(name,password,email,birthday) values('wangwu','123456','wangwu@sina.com','1979-12-04'); 21 */ 22 23 //JDBC的编码步骤： 24 //查询users表中的所有数据，打印到控制台上 25 public class JdbcDemo1 { 26 27 public static void main(String[] args) throws SQLException { 28 // 1、注册驱动 29 DriverManager.registerDriver(new com.mysql.jdbc.Driver()); 30 // 2、获取与数据库的链接 31 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15", "root", "sorry"); 32 //System.out.println(conn.getClass().getName()); 要想知道具体类型，就这么办 33 // 3、创建代表SQL语句的对象 34 Statement stmt = conn.createStatement(); 35 // 4、执行SQL语句 36 ResultSet rs = stmt.executeQuery("select id,name,password,email,birthday from users"); 37 // 5、如果是查询语句，需要遍历结果集 38 while(rs.next()){ 39 System.out.println("---------------------"); 40 System.out.println(rs.getObject("id")); 41 System.out.println(rs.getObject("name")); 42 System.out.println(rs.getObject("password")); 43 System.out.println(rs.getObject("email")); 44 System.out.println(rs.getObject("birthday")); 45 } 46 // 6、释放占用的资源 47 rs.close(); 48 stmt.close(); 49 conn.close(); 50 } 51 52 }
3、运行代码，打印结果：
成功连接， 并读取了数据库中的数据！！！
四、DriverManager详解
DriverManager作用：
a、注册驱动：
方式一：（不建议使用）
DriverManager.registerDriver(new com.mysql.jdbc.Driver());
原因：1、依赖具体驱动。2、导致驱动注册2遍
方式二：（建议）
Class.forName("com.mysql.jdbc.Driver");
b、获取与数据库的链接
url:SUN和数据库厂商间的协议。具体查阅数据库的文档。
public static Connection getConnection(String url,String user,String password) throws SQLException
public static Connection getConnection(String url,Properties info) throws SQLException
public static Connection getConnection(String url) throws SQLException
Connection作用：
所有的数据库操作都是基于链接之上的。
Statement createStatement()：创建向数据库发送sql的statement对象。
所以代码修改为：
1 package com.bigshow1949.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.SQLException; 7 import java.sql.Statement; 8 import java.util.Properties; 9 10 //DriverManager详解 11 public class JdbcDemo2 { 12 13 public static void main(String[] args) throws Exception { 14 //方式一：不建议使用 15 // DriverManager.registerDriver(new com.mysql.jdbc.Driver()); 16 //方式二： 17 Class.forName("com.mysql.jdbc.Driver"); 18 19 //--------------------------------------------------------------------------------------- 20 // 2、获取与数据库的链接 21 //方式一： 22 // Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15", "root", "sorry"); 23 24 //方式二： 25 // Properties props = new Properties(); 26 // props.setProperty("user", "root");// 参数名：参考数据库的文档 27 // props.setProperty("password", "sorry"); 28 // props.setProperty("useUnicode", "true");//编码有关的参数 29 // props.setProperty("characterEncoding", "utf8"); 30 // Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15",props); 31 32 //方式三 33 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15?user=root&password=sorry"); 34 35 //System.out.println(conn.getClass().getName()); 要想知道具体类型，就这么办 36 // 3、创建代表SQL语句的对象 37 Statement stmt = conn.createStatement(); 38 // 4、执行SQL语句 39 ResultSet rs = stmt.executeQuery("select id,name,password,email,birthday from users"); 40 // 5、如果是查询语句，需要遍历结果集 41 while(rs.next()){ 42 System.out.println("---------------------"); 43 System.out.println(rs.getObject("id")); 44 System.out.println(rs.getObject("name")); 45 System.out.println(rs.getObject("password")); 46 System.out.println(rs.getObject("email")); 47 System.out.println(rs.getObject("birthday")); 48 } 49 // 6、释放占用的资源 50 rs.close(); 51 stmt.close(); 52 conn.close(); 53 } 54 55 }
五、Statement详解
作用：代表SQL语句对象。可以向数据库发送任何的SQL语句
ResultSet executeQuery(String sql):sql一般都是查询语句
int executeUpdate(String sql):sql一般是DML语句。insert update delete。返回值，操作几条记录。
boolean execute(String sql):sql可以是任意的语句。返回值不是代表成功与否。如果是查询语句，就有结果集，返回true。没有返回结果集的，返回false。
代码展示：
1 package com.itheima.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.SQLException; 7 import java.sql.Statement; 8 import java.util.Properties; 9 10 //Statement详解 11 public class JdbcDemo3 { 12 13 public static void main(String[] args) throws Exception { 14 Class.forName("com.mysql.jdbc.Driver"); 15 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15", "root", "sorry"); 16 // 3、创建代表SQL语句的对象 17 Statement stmt = conn.createStatement(); 18 19 // int num = stmt.executeUpdate("update users set password=123"); 20 // System.out.println(num); 21 22 // boolean b = stmt.execute("update users set password=111"); 23 // System.out.println(b); 24 25 // boolean b = stmt.execute("select * from users"); 26 // System.out.println(b); 27 // if(b){ 28 // ResultSet rs = stmt.getResultSet(); 29 // } 30 31 stmt.close(); 32 conn.close(); 33 } 34 35 }
六、ResultSet详解
作用：封装了查询的结果集
boolean next():游标下移。返回值是有无记录
boolean previous():游标上移。
boolean absolute(int count):定位到指定的行。第一行是1。
void beforeFirst():移动游标到第一行的前面。
void afterLast():移动游标到最后一行的后面。
先创建一个User类，代码：
1 package com.bigshow1949.user; 2 3 import java.io.Serializable; 4 import java.util.Date; 5 //实体Bean：Enity JavaBean 6 //Java类型和数据库类型：对应关系。相对固定的 7 public class User implements Serializable { 8 private int id; 9 private String name; 10 private String password; 11 private String email; 12 private Date birthday; 13 public int getId() { 14 return id; 15 } 16 public void setId(int id) { 17 this.id = id; 18 } 19 public String getName() { 20 return name; 21 } 22 public void setName(String name) { 23 this.name = name; 24 } 25 public String getPassword() { 26 return password; 27 } 28 public void setPassword(String password) { 29 this.password = password; 30 } 31 public String getEmail() { 32 return email; 33 } 34 public void setEmail(String email) { 35 this.email = email; 36 } 37 public Date getBirthday() { 38 return birthday; 39 } 40 public void setBirthday(Date birthday) { 41 this.birthday = birthday; 42 } 43 @Override 44 public String toString() { 45 return "User [id=" + id + ", name=" + name + ", password=" + password 46 + ", email=" + email + ", birthday=" + birthday + "]"; 47 } 48 49 }
ResultSet代码展示：
1 package com.bigshow1949.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.Statement; 7 import java.util.ArrayList; 8 import java.util.List; 9 10 import com.bigshow1949.user.User; 11 12 //ResultSet详解 13 public class JdbcDemo4 { 14 15 public static void main(String[] args) throws Exception { 16 Class.forName("com.mysql.jdbc.Driver"); 17 Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15", "root", "sorry"); 18 Statement stmt = conn.createStatement(); 19 ResultSet rs = stmt.executeQuery("select id,name,password,email,birthday from users"); 20 // rs.afterLast(); 21 // boolean b = rs.previous(); 22 // if(b){ 23 // User user = new User(); 24 // user.setId(rs.getInt("id")); 25 // user.setName(rs.getString("name")); 26 // user.setPassword(rs.getString("password")); 27 // user.setEmail(rs.getString("email")); 28 // user.setBirthday(rs.getDate("birthday")); 29 // System.out.println(user); 30 // }else{ 31 // System.out.println("没有结果"); 32 // } 33 34 // 5、如果是查询语句，需要遍历结果集 35 List<User> users = new ArrayList<User>(); 36 while(rs.next()){ 37 System.out.println("---------------------"); 38 // System.out.println(rs.getObject("id"));//不考虑字段的类型 39 // System.out.println(rs.getObject("name")); 40 // System.out.println(rs.getObject("password")); 41 // System.out.println(rs.getObject("email")); 42 // System.out.println(rs.getObject("birthday")); 43 44 // System.out.println(rs.getObject(1));//第一列。所用从1开始。 一般很少用，做JDBC有关的框架时用 45 // System.out.println(rs.getObject(2)); 46 // System.out.println(rs.getObject(3)); 47 // System.out.println(rs.getObject(4)); 48 // System.out.println(rs.getObject(5)); 49 User user = new User(); 50 // user.setId((Integer)rs.getObject("id")); 51 user.setId(rs.getInt("id")); 52 user.setName(rs.getString("name")); 53 user.setPassword(rs.getString("password")); 54 user.setEmail(rs.getString("email")); 55 user.setBirthday(rs.getDate("birthday")); 56 57 users.add(user); 58 59 } 60 rs.close(); 61 stmt.close(); 62 conn.close(); 63 64 for(User u:users) 65 System.out.println(u); 66 } 67 68 }
七、释放资源&JDBC编码的代码模板
如果当程序运行到users.add(user);就抛出异常了，那么rs.close();stmt.close();conn.close();就不会运行了，资源就不会释放了，所以要加上finally，不论程序是否异常都会执行，在这里释放资源。如果程序运行到stmt = conn.createStatement();就抛出异常，那么rs的值仍然是null，所以在finally里要判断下是否为null。
1 package com.bigshow1949.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.ResultSet; 6 import java.sql.SQLException; 7 import java.sql.Statement; 8 import java.util.ArrayList; 9 import java.util.List; 10 11 import com.bigshow1949.user.User; 12 13 //释放资源 14 //JDBC编码的代码模板 15 public class JdbcDemo5 { 16 17 public static void main(String[] args) { 18 Connection conn = null; 19 Statement stmt = null; 20 ResultSet rs = null; 21 try { 22 Class.forName("com.mysql.jdbc.Driver"); 23 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/day15", "root", "sorry"); 24 stmt = conn.createStatement(); 25 rs = stmt.executeQuery("select id,name,password,email,birthday from users"); 26 List<User> users = new ArrayList<User>(); 27 while(rs.next()){ 28 User user = new User(); 29 user.setId(rs.getInt("id")); 30 user.setName(rs.getString("name")); 31 user.setPassword(rs.getString("password")); 32 user.setEmail(rs.getString("email")); 33 user.setBirthday(rs.getDate("birthday")); 34 users.add(user); 35 } 36 37 } catch (Exception e) { 38 e.printStackTrace(); 39 }finally{ 40 if(rs!=null){ 41 try { 42 rs.close(); 43 } catch (SQLException e) { 44 e.printStackTrace(); 45 } 46 rs = null; 47 } 48 if(stmt!=null){ 49 try { 50 stmt.close(); 51 } catch (SQLException e) { 52 e.printStackTrace(); 53 } 54 stmt = null; 55 } 56 if(conn!=null){ 57 try { 58 conn.close(); 59 } catch (SQLException e) { 60 e.printStackTrace(); 61 } 62 conn = null; 63 } 64 } 65 66 } 67 68 }
八、Jdbc工具类
我们发现每次增删改查，finally里跟注册里的代码都一样，所以这部分代码单独抽取出来，写一个工具类，所以就有了JdbcUtil工具类。
首先，新建配置文件：dbcfg.properties，把一些字符串变量写在配置文件里，然后程序直接读取配置文件
代码：
1 driverClass=com.mysql.jdbc.Driver 2 url=jdbc:mysql://localhost:3306/day15 3 user=root 4 password=sorry
JdbcUtil工具类代码：
1 package com.bigshow1949.util; 2 3 import java.io.IOException; 4 import java.io.InputStream; 5 import java.sql.Connection; 6 import java.sql.DriverManager; 7 import java.sql.ResultSet; 8 import java.sql.SQLException; 9 import java.sql.Statement; 10 import java.util.Properties; 11 12 //工具类 13 public class JdbcUtil { 14 15 private static String driverClass; 16 private static String url; 17 private static String user; 18 private static String password; 19 20 static{ 21 try { 22 ClassLoader cl = JdbcUtil.class.getClassLoader(); 23 InputStream in = cl.getResourceAsStream("dbcfg.properties"); 24 Properties props = new Properties(); 25 props.load(in); 26 driverClass = props.getProperty("driverClass"); 27 url = props.getProperty("url"); 28 user = props.getProperty("user"); 29 password = props.getProperty("password"); 30 31 Class.forName(driverClass); 32 } catch (Exception e) { 33 throw new ExceptionInInitializerError(e); 34 } 35 } 36 37 38 public static Connection getConnection() throws Exception{ 39 Connection conn = DriverManager.getConnection(url,user, password); 40 return conn; 41 } 42 public static void release(ResultSet rs,Statement stmt,Connection conn){ 43 if(rs!=null){ 44 try { 45 rs.close(); 46 } catch (SQLException e) { 47 e.printStackTrace(); 48 } 49 rs = null; 50 } 51 if(stmt!=null){ 52 try { 53 stmt.close(); 54 } catch (SQLException e) { 55 e.printStackTrace(); 56 } 57 stmt = null; 58 } 59 if(conn!=null){ 60 try { 61 conn.close(); 62 } catch (SQLException e) { 63 e.printStackTrace(); 64 } 65 conn = null; 66 } 67 } 68 }
注意：注册驱动 Class.forName(driverClass);不要写在连接里，不然每次连接都要注册一次驱动，没有必要，初始化一次就够了。
测试代码：
1 package com.bigshow1949.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.ResultSet; 5 import java.sql.Statement; 6 7 import org.junit.Test; 8 9 import com.bigshow1949.util.JdbcUtil; 10 11 public class JdbcDemo6 { 12 13 @Test 14 public void testAdd(){ 15 Connection conn = null; 16 Statement stmt = null; 17 ResultSet rs = null; 18 try{ 19 conn = JdbcUtil.getConnection(); 20 stmt = conn.createStatement(); 21 stmt.executeUpdate("insert into users (name,password,email,birthday) values ('wangwu','123','wangwu@itcast.cn','2000-10-01')"); 22 }catch(Exception e){ 23 throw new RuntimeException(e); 24 }finally{ 25 JdbcUtil.release(rs, stmt, conn); 26 } 27 } 28 @Test 29 public void testUpdate(){ 30 Connection conn = null; 31 Statement stmt = null; 32 ResultSet rs = null; 33 try{ 34 conn = JdbcUtil.getConnection(); 35 stmt = conn.createStatement(); 36 stmt.executeUpdate("update users set password=111 where id=4"); 37 }catch(Exception e){ 38 throw new RuntimeException(e); 39 }finally{ 40 JdbcUtil.release(rs, stmt, conn); 41 } 42 } 43 @Test 44 public void testDelete(){ 45 Connection conn = null; 46 Statement stmt = null; 47 ResultSet rs = null; 48 try{ 49 conn = JdbcUtil.getConnection(); 50 stmt = conn.createStatement(); 51 stmt.executeUpdate("delete from users where id=1"); 52 }catch(Exception e){ 53 throw new RuntimeException(e); 54 }finally{ 55 JdbcUtil.release(rs, stmt, conn); 56 } 57 } 58 }
九、项目文件结构
项目代码下载：
https://github.com/BigShow1949/01-JDBC