JDBC概述
为了使Java编写的程序不依赖于具体的数据库，Java提供了专门用于操作的API，即JDBC（Java Data Base Connectivity），JDBC其实是一组接口，用于规范操作各数据库，而接口的实现由不同数据库厂商所实现，而这些实现了JDBC接口的类就是我们平时所导的jar包了。JDBC操作不同的数据库仅仅是连接方式上的差异而已，使用JDBC的应用程序一旦和数据库建立连接，就可以使用JDBC提供的API操作数据库。
具体流程
由于Statement存在sql注入问题，所以我们在下面的例子使用PreparedStatement。
创建表以及相对应的对象（ORM）
ORM思想
（1）一个数据表对应一个Java类。
（2）表中的一条记录对应Java类的一个对象。
（3）表中的一个字段对应Java类的一个属性。
表
对象
package com.xxx.bean; public class Student { private String id; private String name; private Integer age; private String sex; public Student() { } public Student(String id, String name, Integer age, String sex) { this.id = id; this.name = name; this.age = age; this.sex = sex; } public String getId() { return id; } public void setId(String id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Integer getAge() { return age; } public void setAge(Integer age) { this.age = age; } public String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } @Override public String toString() { return "Student{" + "id='" + id + '\'' + ", name='" + name + '\'' + ", age=" + age + ", sex='" + sex + '\'' + '}'; } }
获取连接的方式
方式一
（1）获取实现了JDBC规范中Driver接口的实现类，即com.mysql.cj.jdbc.Driver，用它创建对象这样就获取了驱动。
（2）通过com.mysql.cj.jdbc.Driver类中的connect(url,info)方法获取连接对象。
url:统一资源定位符，协议（jdbc:mysql）+ip（xxx.xxx.xxx.xxx）+端口(3306)+具体数据库(database name)。
info:Properties对象，此处的info是封装了用户信息的Properties对象。
代码
@Test public void testConnection1() throws SQLException { //1、获取mysql的驱动（具体实现JDBC接口的Driver类） Driver driver = new com.mysql.cj.jdbc.Driver();//接口回调，前面的Driver是java.sql包的接口 String url="jdbc:mysql://localhost:3306/test"; Properties info = new Properties(); //将用户名和密码封装在Properties中 info.setProperty("user","root"); info.setProperty("password","123456"); //2、通过com.mysql.cj.jdbc.Driver类中的connect(url,info)方法获取连接对象。 Connection conn=driver.connect(url,info); System.out.println(conn); }
方式二
方式二较方式一而言代码具有了更好的移植性。为什么呢？因为方式一中的下面这个代码用到了第三方的类。
Driver driver = new com.mysql.cj.jdbc.Driver();
所以方式二采用反射的方式获取Driver对象，使得代码中无第三方API出现。
代码
@Test public void testConnection2() throws ClassNotFoundException, InstantiationException, IllegalAccessException, SQLException { //全部是sun公司的API，无第三方API，使代码具有更好的移植性 //1、获取Driver实现类对象，使用反射 Class clazz=Class.forName("com.mysql.cj.jdbc.Driver"); Driver driver = (Driver)clazz.newInstance(); //2、提供要连接的数据库 String url = "jdbc:mysql://localhost:3306/test"; //3、提供连接需要的用户名和密码 Properties info = new Properties(); info.setProperty("user","root"); info.setProperty("password","123456"); //4、获取连接 Connection conn = driver.connect(url, info); System.out.println(conn); }
方式三
（1）使用DriverManager类的registerDriver(driver)方法进行注册驱动.
（2）使用DriverManager类的getConnection(url, user, password)方法获取连接对象。
代码
@Test public void testConnection3() throws ClassNotFoundException, InstantiationException, IllegalAccessException, SQLException { //1、获取Driver实现类对象，使用反射 Class clazz=Class.forName("com.mysql.cj.jdbc.Driver"); Driver driver = (Driver)clazz.newInstance(); //2、提供三个连接的基本信息 String url="jdbc:mysql://localhost:3306/test"; String user="root"; String password="123456"; //注册驱动 DriverManager.registerDriver(driver); //获取连接 Connection connection = DriverManager.getConnection(url, user, password); System.out.println(connection); }
方式四
较方式三而言可以省略如下代码：
Driver driver = (Driver)clazz.newInstance(); DriverManager.registerDriver(driver);
为什么没有创建Driver和注册Driver也可以呢？因为在com.mysql.cj.jdbc.Driver中有如下静态代码块帮我们实现了这些操作。
com.mysql.cj.jdbc.Driver源码：
代码
@Test public void testConnection4() throws ClassNotFoundException, SQLException { //1、提供另外三个连接的基本信息 String url="jdbc:mysql://localhost:3306/test"; String user="root"; String password="123456"; //2、获取Driver实现类对象，使用反射 Class.forName("com.mysql.cj.jdbc.Driver"); //获取连接 Connection connection = DriverManager.getConnection(url, user, password); System.out.println(connection); }
方式五（推荐使用）
方式五采用配置文件的方式，当然这也是使用最多的方式。我们将“个人信息”写在配置文件jdbc.properties中，然后通过类加载器读取文件，并通过Properties对象获取配置文件中的键值对。
使用此方式的好处是：
（1）实现了数据与代码的分离，实现了解耦。
（2）如果需要修改配置文件信息，可以避免程序重新打包。
配置文件
user=root password=123456 url=jdbc:mysql://localhost:3306/test s=com.mysql.cj.jdbc.Driver
代码
@Test public void testConnection5() throws IOException, ClassNotFoundException, SQLException { //1、读取配置文件中的四个基本信息 InputStream is = DemoJDBC.class.getClassLoader().getResourceAsStream("jdbc.properties"); Properties pros = new Properties(); pros.load(is); String user=pros.getProperty("user"); String password=pros.getProperty("password"); String url=pros.getProperty("url"); String s=pros.getProperty("s"); System.out.println(s); //2、加载驱动 Class.forName(s); //3、获取连接 Connection conn = DriverManager.getConnection(url, user, password); System.out.println(conn); }
由于数据库的连接和关闭是通用操作，所以将其封装在JDBCUtil类中。
//操作数据库的工具类 //工具类一般都是静态方法 public class JDBCUtils { //获取数据库连接 public static Connection getConnection() throws Exception { Connection conn = null; try { //1、读取配置文件中的四个基本信息 InputStream is = ClassLoader.getSystemClassLoader().getResourceAsStream("jdbc.properties"); Properties pros = new Properties(); pros.load(is); String user=pros.getProperty("user"); String password=pros.getProperty("password"); String url=pros.getProperty("url"); String s=pros.getProperty("s"); //2、加载驱动 Class.forName(s); //3、获取连接 conn = DriverManager.getConnection(url, user, password); } catch (IOException e) { e.printStackTrace(); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException throwables) { throwables.printStackTrace(); } finally { if (conn!=null){ try { return conn; } catch (Exception e) { e.printStackTrace(); } } } return conn; } //关闭数据库连接(closeResource方法重载) public static void closeResource(Connection conn, Statement ps){ if (ps!=null){ try { ps.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } if (conn!=null){ try { conn.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } } //关闭数据库连接(closeResource方法重载) public static void closeResource(Connection conn, Statement ps, ResultSet rs){ if (ps!=null){ try { ps.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } if (conn!=null){ try { conn.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } if (rs!=null){ try { rs.close(); } catch (SQLException throwables) { throwables.printStackTrace(); } } } }
增、删、改操作
代码
//通用的增删改操作 public void update(String sql,Object ...args) throws Exception {//sql中占位符的个数与可变形参的长度相同 //1、获取数据库的连接 Connection conn = JDBCUtils.getConnection(); //2、预编译sql语句，返回PreparedStatement的实例 PreparedStatement ps = conn.prepareStatement(sql); //3、填充占位符 for (int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } //4、执行 ps.execute(); //5、资源关闭 JDBCUtils.closeResource(conn,ps); }
查询操作
通用查询操作，可针对不同表、不同参数。返回集合。
//返回集合 public <T> List<T> getForList(Class<T> clazz, String sql, Object ...args){ Connection conn = null; PreparedStatement ps = null; ResultSet rs= null; ArrayList<T> list = null; try { conn = JDBCUtils.getConnection(); ps = conn.prepareStatement(sql); for (int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } //结果本身在ResultSet中，修饰结果的列名、列列数之类的在元数据中 rs = ps.executeQuery(); //获取结果集的元数据：ResultSetMetaData ResultSetMetaData rsmd = rs.getMetaData(); //System.out.println(rsmd); //通过ResultSetMetaData获取结果集中的列数 int columnCount = rsmd.getColumnCount(); //创建集合对象 list = new ArrayList<>(); while (rs.next()){ T t = clazz.newInstance(); //处理结果集一行数据中的每列：给t对象指定的属性赋值 for (int i=0;i<columnCount;i++){ Object columValue = rs.getObject(i + 1); //获取每个列的列名 //String columName=rsmd.getColumnName(i+1); //获取列的别名(无别名，使用列名) String columName=rsmd.getColumnLabel(i+1); //给指定对象指定的columName属性，赋值为columValue，通过反射 Field field = clazz.getDeclaredField(columName); field.setAccessible(true); field.set(t,columValue); } list.add(t); } return list; } catch (Exception e) { e.printStackTrace(); } finally { JDBCUtils.closeResource(conn,ps,rs); } return null; }
