一、什么是JDBC
JDBC（Java DataBase Connectivity）就是Java数据库连接，说白了就是用Java语言来操作数据库。原来我们操作数据库是在控制台使用SQL语句来操作数据库，JDBC是用Java语言向数据库发送SQL语句。
组成JDBC的２个包：
java.sql
javax.sql
开发JDBC应用需要以上2个包的支持外，还需要导入相应JDBC的数据库实现(即数据库驱动)。
二、实现代码
package cn.zy.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import org.junit.Test;public class Demo01 {
/*
* 得到数据库连接
*/
public static Connection getConnection() throws Exception{
//加载驱动
Class.forName("com.mysql.jdbc.Driver");
//mysql的url
String url = "jdbc:mysql://localhost:3306/testdb";
Connection con = DriverManager.getConnection(url,"root","123456");
return con;
} /*
* 实现增删改
*/
@Test
public void insert() throws Exception{
//得到连接
Connection con = getConnection();
//Statement语句的发送器，它的功能就是向数据库发送sql语句！
Statement stmt = con.createStatement();
String sql = "insert user(name,password) value('scott','tiger')";
//执行sql
stmt.executeUpdate(sql);
}
/*
* 查询
*/
@Test
public void query() throws Exception{
Connection con = getConnection();
Statement stmt = con.createStatement();
String sql = "select * from user";
//得到查询出来的结果集
ResultSet rs = stmt.executeQuery(sql);
//输出查询到的结果
while (rs.next()){
String username = rs.getString("name");
String password = rs.getString("password");
System.out.println(username + ','+ password);
}
/*
* 关闭资源
*/
rs.close();
stmt.close();
con.close();
}
}
三、JDBC对象介绍
在JDBC中常用的类有：
- DriverManager
- Connection
- Statement
- ResultSet
3.1 DriverManager
Jdbc程序中的DriverManager用于加载驱动，并创建与数据库的链接，这个API的常用方法：
DriverManager.getConnection(url, user, password);
常用数据库URL地址的写法：
- Oracle写法：jdbc:oracle:thin:@localhost:1521:sid （driverClassName:oracle.jdbc.driver.OracleDriver）
- SqlServer写法：jdbc:microsoft:sqlserver://localhost:1433; DatabaseName=sid
- MySql写法：jdbc:mysql://localhost:3306/sid
3.2 Connection
Jdbc程序中的Connection，它用于代表数据库的链接，Collection是数据库编程中最重要的一个对象，客户端与数据库所有交互都是通过connection对象完成的，这个对象的常用方法：
- createStatement()：创建向数据库发送sql的statement对象。
- prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。
- prepareCall(sql)：创建执行存储过程的callableStatement对象。
- setAutoCommit(boolean autoCommit)：设置事务是否自动提交。
- commit() ：在链接上提交事务。
- rollback() ：在此链接上回滚事务。
3.3 Statement
Jdbc程序中的Statement对象用于向数据库发送SQL语句， Statement对象常用方法：
- executeQuery(String sql) ：用于向数据发送查询语句。
- executeUpdate(String sql)：用于向数据库发送insert、update或delete语句
- execute(String sql)：用于向数据库发送任意sql语句
- addBatch(String sql) ：把多条sql语句放到一个批处理中。
- executeBatch()：向数据库发送一批sql语句执行。
3.4 ResultSet
Jdbc程序中的ResultSet用于代表Sql语句的执行结果。Resultset封装执行结果时，采用的类似于表格的方式。ResultSet 对象维护了一个指向表格数据行的游标，初始的时候，游标在第一行之前，调用ResultSet.next() 方法，可以使游标指向具体的数据行，进行调用方法获取该行的数据。
ResultSet既然用于封装执行结果的，所以该对象提供的都是用于获取数据的get方法：
获取任意类型的数据
getObject(int index)
getObject(string columnName)
获取指定类型的数据，例如：
getString(int index)
getString(String columnName)
ResultSet还提供了对结果集进行滚动的方法：
- next()：移动到下一行
- Previous()：移动到前一行
- absolute(int row)：移动到指定行
- beforeFirst()：移动resultSet的最前面。
- afterLast() ：移动到resultSet的最后面。
3.5 PreparedStatement
PreperedStatement是Statement的子类，它的实例对象可以通过调用Connection.preparedStatement()方法获得，相对于Statement对象而言：PreperedStatement可以避免SQL注入的问题。在实际项目中，应该都使用PreparedStatement.
Statement会使数据库频繁编译SQL，可能造成数据库缓冲区溢出。PreparedStatement可对SQL进行预编译，从而提高数据库的执行效率。并且PreperedStatement对于sql中的参数，允许使用占位符的形式进行替换，简化sql语句的编写。
注意MySQL中默认是没有开启预编译的，如果需要打开需要修改url：jdbc:mysql://localhost:3306/test?useServerPrepStmts=true
四、使用JdbcUtils和PreparedStatement
1. 创建users表
CREATE TABLE users(
id INT PRIMARY KEY,
NAME VARCHAR(40),
PASSWORD VARCHAR(40),
email VARCHAR(60),
birthday DATE
);
2. 新建一个Java工程，导入驱动包，在src下创建一个db.properties文件
在db.properties中编写MySQL数据库的连接信息，如下所示：
driver=com.mysql.jdbc.Driver
url=jdbc\:mysql\://localhost\:3306/testdb
username=root
password=123456
3.编写一个JdbcUtils工具类，用于连接数据库，获取数据库连接和释放数据库连接，代码如下：
package cn.zy.utils;import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;public class JdbcUtils {
private static Properties props = null;
private static String driver = null;
private static String url = null;
private static String username = null;
private static String password = null;
//只在JdbcUtils类被加载时执行一次！
static {
try {
// 给props进行初始化，即加载dbconfig.properties文件到props对象中
InputStream in = JdbcUtils.class.getClassLoader().getResourceAsStream("db.properties");
Properties prop = new Properties();
prop.load(in); //获取数据库的驱动
driver = prop.getProperty("driver");
//获取url
url= prop.getProperty("url");
//获取用户名
username = prop.getProperty("username");
//获取密码
password = prop.getProperty("password");
//加载驱动
Class.forName(driver);
} catch (Exception e) {
throw new ExceptionInInitializerError(e);
}
} /*
* 获取数据库连接对象
*/
public static Connection getConnection() throws SQLException{
return DriverManager.getConnection(url,username,password);
} /*
* 释放资源
*/
public static void release(Connection conn,Statement st,ResultSet rs){
if(rs!=null){
try{
//关闭存储查询结果的ResultSet对象
rs.close();
}catch (Exception e) {
e.printStackTrace();
}
rs = null;
}
if(st!=null){
try{
//关闭负责执行SQL命令的Statement对象
st.close();
}catch (Exception e) {
e.printStackTrace();
}
} if(conn!=null){
try{
//关闭Connection数据库连接对象
conn.close();
}catch (Exception e) {
e.printStackTrace();
}
}
}
}
4.使用PreparedStatement实现增删改查
package cn.zy.test;import java.sql.Connection;
import java.util.Date;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;import org.junit.Test;import cn.zy.utils.JdbcUtils;public class JdbcUtilsTest {
@Test
public void insert(){
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try {
//获取一个数据库连接
conn = JdbcUtils.getConnection();
//要执行的SQL模板，SQL中的参数使用?作为占位符
String sql = "insert into users(id,name,password,email,birthday) values(?,?,?,?,?)";
//通过conn对象获取负责执行SQL命令的prepareStatement对象
st = conn.prepareStatement(sql);
//为SQL语句中的参数赋值，注意，索引是从1开始的
st.setInt(1, 1);
st.setString(2,"scott");
st.setString(3,"tiger");
st.setString(4, "zy5724@163.com");
st.setDate(5, new java.sql.Date(new Date().getTime()));
int num = st.executeUpdate();
if (num>0){
System.out.print("更新成功");
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
} @Test
public void query(){
Connection conn = null;
PreparedStatement st = null;
ResultSet rs = null;
try {
//获取一个数据库连接
conn = JdbcUtils.getConnection();
//要执行的SQL模板，SQL中的参数使用?作为占位符
String sql = "select * from users where id=?";
//通过conn对象获取负责执行SQL命令的prepareStatement对象
st = conn.prepareStatement(sql);
st.setInt(1, 1);
rs = st.executeQuery();
if (rs.next()){
System.out.println(rs.getString("name"));
}
} catch (SQLException e) {
e.printStackTrace();
}finally{
JdbcUtils.release(conn, st, rs);
}
}
}
