1.基本概念
JDBC是一个独立于特定数据管理系统.通用的SQL数据库存取和操作的公共接口(一组API),定义了访问数据库的标准java类库,使用这个类库可以以一种标准的方法,便捷的访问数据库资源。
JDBC是java应用程序连接数据库的接口,该接口的实现类是由JDBC来实现的,JDBC驱动是由个大数据库厂商锁提供的对JDBC的实现类库。
(一)JDBC接口
JDBC接口包括二个方面:
面向应用的API:Java API,接口抽象,供应用程序开发人员使用(连接数据库,执行SQL语句,获得结果)。
面向数据库的API:Java Driver API,供开发商开发数据库驱动程序使用。
(二)JDBC驱动
各个数据库厂商根据JDBC的规范制作的JDBC实现类的类库
JDBC驱动程序包括4种类型:
1.JDBC-ODBC桥
2.部分本地API部分java驱动程序
3.JDBC网络纯java驱动程序
4.本地协议的纯java驱动程序
3,4类都是纯java的驱动程序,因此,对于java开发者来说,他么在性能,可移植性,功能等方面都有优势。
(三)Driver Manager
2.通过Driver接口获取数据库连接
java.sql.Driver接口是所有的JDBC驱动程序都要实现的接口,这个接口是提供给数据库厂商使用的,不同的数据库厂商提供了不同的实现。
在程序当中不需要直接去访问Driver接口的类,而是由驱动程序管理器类(java.sql.DruverManager)去调用那些Driver的实现。
原始版本:复用性差
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.SQLException;
import java.util.Properties;
import org.junit.jupiter.api.Test;
/**
* 通过Driver的实现类对象来获取数据库连接
* @author laochaochunfengting
*
*/
class JDBCTest {
/**
* Driver是一个接口,是一个驱动必须要实现的接口,在本地没有它的实现
* 数据库厂商必须提供实现的接口,才能从中获取数据库连接
* 引入mysql驱动mysql-connector-java.jar
* @throws SQLException
*/
@Test
void testDriver() throws SQLException {
/**
* 创建一个Driver实现类的对象
* java.sql.Driver接口的实现是mysql驱动com.mysql.jdbc.Driver
*/
Driver driver=new com.mysql.jdbc.Driver();
/**
* 准备连接数据库的基本信息:URL,user,password
* 注意put的key必须是user,password,
*/
String url="jdbc:mysql://localhost:3306/spring";
Properties info=new Properties();
info.put("user", "root");
info.put("password", "bzq18107155240");
/**
* 调用Driver接口的connect(url,info)方法获取数据库连接
*/
Connection connection=driver.connect(url, info);
System.out.println(connection);
}
}
改进版本:
*******************************jdbc.properties**********************************
driverClass=com.mysql.jdbc.Driver
jdbcUrl=jdbc:mysql://localhost:3306/spring
user=root
password=bzq18107155240
#driver=oracle.jdbc.driver.OracleDriver
#jdbcUrl=jdbc:oracle:thin:@localhost:1521:spring
#user=scott
#password=java
**********************************************************************************
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.SQLException;
import java.util.Properties;
import org.junit.jupiter.api.Test;
/**
* 通过Driver接口的实现类对象来获取数据库连接
* @author laochaochunfengting
*
*/
class JDBCTest {
/**
* 编写一个通用的方法,在不修改源程序的情况下,可以获取任意数据库的连接
* 解决方案:
* 把数据库驱动Driver实现类的全类名,url,user,password放入到一个配置文件当中,
* 通过修改配置文件的方式实现和具体的数据库解耦
* @throws ClassNotFoundException
* @throws IllegalAccessException
* @throws InstantiationException
* @throws SQLException
* @throws IOException
*/
public Connection getConnection() throws InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException, IOException {
String driverClass=null;
String jdbcUrl=null;
String user=null;
String password=null;
//读取类路径下的jdbc.properties属性文件
InputStream in=getClass().getClassLoader().getResourceAsStream("jdbc.properties");
Properties prop=new Properties();
prop.load(in);
driverClass=prop.getProperty("driverClass");
jdbcUrl=prop.getProperty("jdbcUrl");
user=prop.getProperty("user");
password=prop.getProperty("password");
/**
* 通过反射读取驱动类对象
*/
Driver driver=(Driver) Class.forName(driverClass).newInstance();
Properties info=new Properties();
info.put("user", user);
info.put("password", password);
/**
* 通过DriverClass的connect方法连接数据库
*/
Connection connection=driver.connect(jdbcUrl, info);
return connection;
}
@Test
public void testGetConnection() throws InstantiationException, IllegalAccessException, ClassNotFoundException, SQLException, IOException {
System.out.println(getConnection());
}
}
3.通过DriverManager来获得数据库连接
DriverManager是驱动的管理类
* 1.可以通过重载的getConnection()方法获取数据库连接,较为方便
* 2.可以同时管理多个驱动程序:若注册了多个数据库连接,则调用getConnection()方法是传入的参数不同,即返回不同的数据库连接.
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
import org.junit.jupiter.api.Test;
/**
* 通过DriverManager来连接数据库
* @author laochaochunfengting
*/
class JDBCDriverManagerTest {
/**
* DriverManager是驱动的管理类
* 1.可以通过重载的getConnection()方法获取数据库连接,叫为方便
* 2.可以同时管理多个驱动程序:若注册了多个数据库连接,则调用getConnection()方法是传入的参数不同,
* 即返回不同的数据库连接
* @throws IOException
* @throws SQLException
* @throws ClassNotFoundException
*/
@Test
public void testDriverManager() throws IOException, SQLException, ClassNotFoundException {
String driverClass=null;
String jdbcUrl=null;
String user=null;
String password=null;
//读取类路径下的jdbc.properties属性文件
InputStream in=getClass().getClassLoader().getResourceAsStream("jdbc.properties");
Properties prop=new Properties();
prop.load(in);
driverClass=prop.getProperty("driverClass");
jdbcUrl=prop.getProperty("jdbcUrl");
user=prop.getProperty("user");
password=prop.getProperty("password");
//注册/加载数据库驱动程序(对应的Driver实现类当中有注册驱动的静态代码块)
Class.forName(driverClass);
//DriverManager.registerDriver(Class.forName(driverClass).newInstance());
Connection connection=DriverManager.getConnection(jdbcUrl, user, password);
System.out.println(connection);
}
public Connection DriverManager1() throws IOException, ClassNotFoundException, SQLException {
/**
* 1.准备连接数据库的4个字符串
* 1)创建Properties属性对象
* 2) 获取属性文件
* 3)加载属性文件
* 4)获取属性文件的值
*/
Properties prop=new Properties();
InputStream in=getClass().getClassLoader().getResourceAsStream("jdbc.properties");
prop.load(in);
String driverClass=prop.getProperty("driverClass");
String jdbcUrl=prop.getProperty("jdbcUrl");
String user=prop.getProperty("user");
String password=prop.getProperty("password");
//2.加载数据库驱动
Class.forName(driverClass);
//3.通过DriverManager的getConnection()方法连接数据库
return DriverManager.getConnection(jdbcUrl, user, password);
}
@Test
public void testDriverManager1() throws ClassNotFoundException, IOException, SQLException {
System.out.println(DriverManager1());
}
}
4.对数据库进行操作
要对数据库进行增删改查操作,就必须要使用Statement进行,只有这个对象具有对数据库操作的权限,Connection没有操作的权限,故连接到数据库之后的第一步就是获得Statement对象。
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;
import org.junit.jupiter.api.Test;
/**
* 通过DriverManager来连接数据库
* @author laochaochunfengting
*/
class JDBCDriverManagerTest {
/**
* 向数据库表当中插入一条数据
* @throws SQLException
* @throws IOException
* @throws ClassNotFoundException
*
* 注意:1.Statement:用于执行SQL语句的对象
* 1)通过Connection的createStatement()方法来获取
* 2)通过executeUpadate(sql)可以执行SQL语句
* 3)传入的SQL可以是INSERT,UPDATE,DELETE,但不能是SELECT
* 2.Connection,Statement都是应用程序和数据库服务器的连接资源,使用后一定要关闭
* 一般在finally里面关闭,因为如果在插入操作完成之后,执行一条错误的语句,不再finally里面就关闭不了了。
*
*/
@Test
public void testStatement() throws ClassNotFoundException, IOException, SQLException {
//1.获取数据库连接
Connection connection=DriverManager1();
//2.准备插入的SQL
String sql="insert into customers(name,email,birth) values('aini','aini@163.com','2088-10-12')";
/**
* 3.执行插入
* 1.)获取SQL语句的Statement对象:调用Connection的createStatement()方法来获取
* 2.)调用Statement对象的executeUpdate(sql)执行SQL语句进行插入
*/
Statement statement=connection.createStatement();
statement.executeUpdate(sql);
//4.关闭连接
statement.close();
connection.close();
}
public Connection DriverManager1() throws IOException, ClassNotFoundException, SQLException {
/**
* 1.准备连接数据库的4个字符串
* 1)创建Properties属性对象
* 2) 获取属性文件
* 3)加载属性文件
* 4)获取属性文件的值
*/
Properties prop=new Properties();
InputStream in=getClass().getClassLoader().getResourceAsStream("jdbc.properties");
prop.load(in);
String driverClass=prop.getProperty("driverClass");
String jdbcUrl=prop.getProperty("jdbcUrl");
String user=prop.getProperty("user");
String password=prop.getProperty("password");
//2.加载数据库驱动
Class.forName(driverClass);
//3.通过DriverManager的getConnection()方法连接数据库
return DriverManager.getConnection(jdbcUrl, user, password);
}
}
5.通过ResultSet对查询的结果进行操作
通过JDBC对数据库进行查询操作的时候,返回的结果实际可以看成是一张表,保存在集合当中的表,有一个指针指向数据表的第一行的前面,可以调用next()方法检测下一行是否有效,若返回true,且指针下移,相当于hasNext(),next()即集合。
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
import java.util.Properties;
import org.junit.jupiter.api.Test;
/**
* 通过DriverManager来连接数据库
* @author laochaochunfengting
*/
class JDBCDriverManagerTest {
/**
* ResultSet:结果集,封装了使用JDBC查询的结果
* 1.调用Statement对象的executeQuery(sql)得到结果集
* 2.ResultSet返回的实际就是一张数据表,有一个指针指向数据表的第一行的前面,
* 可以调用next()方法检测下一行是否有效,若返回true,且指针下移,相当于hasNext(),next()即集合
* 3.当指针对到到一行的时候,可以通过getXXX(index)或者getXxx(columnName)获取每一列的值
* 4.ResultSet当然也要关闭
* @throws SQLException
* @throws IOException
* @throws ClassNotFoundException
*/
@Test
public void testResultSet() throws ClassNotFoundException, IOException, SQLException {
//获取ID=3的customers数据表的记录,并打印
Connection connection=null;
Statement statement=null;
ResultSet resultSet=null;
try {
//1.获取连接
connection=JDBCTools.getConnection();
//2.获取Statement
statement=connection.createStatement();
//3.准备sql
String sql="select * from customers where id=3";
//4.指向查询,返回ResultSet
resultSet=statement.executeQuery(sql);
//5.处理ResultSet
if(resultSet.next()) {
int id=resultSet.getInt(1);
String name=resultSet.getString("name");
String email=resultSet.getString(3);
Date date=resultSet.getDate(4);
System.out.println(id);
System.out.println(name);
System.out.println(email);
System.out.println(date);
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
//6.关闭连接
JDBCTools.releaseSource(statement, connection, resultSet);
}
}
}
***********************************返回结果为多行********************************
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Date;
import java.util.Properties;
import org.junit.jupiter.api.Test;
/**
* 通过DriverManager来连接数据库
* @author laochaochunfengting
*/
class JDBCDriverManagerTest {
/**
* ResultSet:结果集,封装了使用JDBC查询的结果
* 1.调用Statement对象的executeQuery(sql)得到结果集
* 2.ResultSet返回的实际就是一张数据表,有一个指针指向数据表的第一行的前面,
* 可以调用next()方法检测下一行是否有效,若返回true,且指针下移,相当于hasNext(),next()即集合
* 3.当指针对到到一行的时候,可以通过getXXX(index)或者getXxx(columnName)获取每一列的值
* 4.ResultSet当然也要关闭
* @throws SQLException
* @throws IOException
* @throws ClassNotFoundException
*/
@Test
public void testResultSet() throws ClassNotFoundException, IOException, SQLException {
//获取ID=3的customers数据表的记录,并打印
Connection connection=null;
Statement statement=null;
ResultSet resultSet=null;
try {
//1.获取连接
connection=JDBCTools.getConnection();
//2.获取Statement
statement=connection.createStatement();
//3.准备sql
String sql="select * from customers";
//4.指向查询,返回ResultSet
resultSet=statement.executeQuery(sql);
//5.处理ResultSet
while(resultSet.next()) {
int id=resultSet.getInt(1);
String name=resultSet.getString("name");
String email=resultSet.getString(3);
Date date=resultSet.getDate(4);
System.out.println(id);
System.out.println(name);
System.out.println(email);
System.out.println(date);
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
//6.关闭连接
JDBCTools.releaseSource(statement, connection, resultSet);
}
}
}
6.PreparedStatement使用
1.使用PreparedStatement
1.创建PreparedStatement
String sql=""insert into examStudent values(?,?,?,?,?,?,?);
PreparedStatememt ps=conn.preparedStatement(sql);
调用PreparedStatementd的setXxx(int index,Object value)方法设置占位符的值。
2.执行SQL语句:executeQUery()/executeUpdate(),注意执行时无需传入sql语句
3.PreparedStatement:Statement的子接口,可以传入带占位符的SQL语句,并且提供了补充占位符变量的方法
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Scanner;
import org.junit.jupiter.api.Test;
/**
* 在测试方法testAddNewStudent()当中
* 1.获取从控制台输入的Student对象,Student student=getStudentFromConsole
* @author laochaochunfengting
*
*/
class JDBCTest2 {
@Test
public void testGetPreparedStatement() {
Connection connection=null;
PreparedStatement preparedStatement=null;
ResultSet resultSet=null;
try {
String sql="insert into customers(name,email,birth) values(?,?,?)";
connection=JDBCTools.getConnection();
preparedStatement=connection.prepareStatement(sql);
preparedStatement.setString(1, "黑瞳");
preparedStatement.setString(2, "thei@163.com");
/**
* 注意此处在传入date的时候必须是传入java.sql下的date
*
* 在创建java.sql.date下的date的时候,这个date的构造器都是有参构造器
* Date(int year,int month,int day),Date(long date),我们使用第二个,他是1970年到现在的毫秒数
*
* java.util.date下的date有个方法getTime()返回的就是1970年到现在的毫秒数
*/
//preparedStatement.setDate(3, new Date(new java.util.Date().getTime()));
preparedStatement.setString(3, "1684-1-19");
preparedStatement.executeUpdate();
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
JDBCTools.releaseSource(preparedStatement, connection, resultSet);
}
}
7.使用JDBC驱动程序获取元数据
ResultSetData:描述ResultSet的元素的数据对象,即从中获取到结果集当中有多少列,列名是什么....
1.得到ResultSetData对象:调用ResultSetd的getMetaData()方法
int getColumn():sql语句当中包含那些列
String getColumnLable(int column):获取指定列的别名,从索引1开始
package com.neuSoft.jdbc;
import static org.junit.jupiter.api.Assertions.*;
import java.io.IOException;
import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Map;
import java.util.Scanner;
import org.junit.jupiter.api.Test;
class JDBCTest3 {
/**
* ResultSetData:描述ResultSet的元素的数据对象,即从中获取到结果集当中有多少列,列名是什么....
* 1.得到ResultSetData对象:调用ResultSetd的getMetaData()方法
*
* int getColumn():sql语句当中包含那些列
* String getColumnLable(int column):获取指定列的别名,从索引1开始
* @param ResultSetMetaData
* @throws IllegalAccessException
* @throws InstantiationException
*/
@Test
public void testResultSetMetaData() throws InstantiationException, IllegalAccessException {
Connection connection=null;
PreparedStatement preparedStatement=null;
ResultSet resultSet=null;
try {
String sql="select flowId ,type examType,IdCard idCard,examCard,studentName,location,grade from examstudent where flowId=?";
connection=JDBCTools.getConnection();
preparedStatement=connection.prepareStatement(sql);
preparedStatement.setInt(1, 6);
resultSet=preparedStatement.executeQuery();
Map<String ,Object> map=new HashMap<>();
//1.得到ResultSetData对象
ResultSetMetaData rsmd=resultSet.getMetaData();
while(resultSet.next()) {
for(int i=0;i<rsmd.getColumnCount();i++) {
//注意在获取列值的时候,mysql是从1开始的,故此处要+1
String columnLable=rsmd.getColumnLabel(i+1);
Object columnValue=resultSet.getObject(columnLable);
map.put(columnLable, columnValue);
}
}
System.out.println(map);
Class clazz=Student.class;
Object object=clazz.newInstance();
//2.获取打印一列的别名
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally {
JDBCTools.releaseSource(preparedStatement, connection, resultSet);
}
}
}