JDBC连接数据库
- 三种连接数据库方式
import org.junit.Test;
import java.sql.Connection;
import java.sql.Driver;
import java.sql.DriverManager;
import java.util.Properties;
public class Test_JDBC_Connect {
/*
jdbc协议:数据库子协议://主机:端口/连接的数据库
*/
private String url = "jdbc:mysql://192.168.64.131:3306";
// 用户名
private String user = "root";
// 密码
private String password = "mysql";
/**
* 第一种方法
*
* @throws Exception e
*/
@Test
public void testJDBC1() throws Exception {
//1.创建驱动程序类对象
Driver driver = new com.mysql.jdbc.Driver(); //新版本
//Driver driver = new org.gjt.mm.mysql.Driver(); //旧版本
//设置用户名和密码
Properties props = new Properties();
props.setProperty("user", user);
props.setProperty("password", password);
//2.连接数据库，返回连接对象
Connection conn = driver.connect(url, props);
System.out.println(conn);
}
/**
* 使用驱动管理器类连接数据库(注册了两次，没必要)
*
* @throws Exception e
*/
@Test
public void testJDBC2() throws Exception {
Driver driver = new com.mysql.jdbc.Driver();
//Driver driver2 = new com.oracle.jdbc.Driver();
//1.注册驱动程序(可以注册多个驱动程序)
DriverManager.registerDriver(driver);
//DriverManager.registerDriver(driver2);
//2.连接到具体的数据库
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
/**
* （推荐使用这种方式连接数据库）
* 推荐使用加载驱动程序类 来 注册驱动程序
*
* @throws Exception 异常
*/
@Test
public void testJDBC3() throws Exception {
//通过得到字节码对象的方式加载静态代码块，从而注册驱动程序
Class.forName("com.mysql.jdbc.Driver");
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
}
JDBC接口核心的API
java.sql.* 和 javax.sql.*
-
Driver接口： 表示java驱动程序接口。所有的具体的数据库厂商要来实现此接口。
- connect(url, properties): 连接数据库的方法。
- url: 连接数据库的URL
- URL语法： jdbc协议:数据库子协议://主机:端口/数据库
- user： 数据库的用户名
- password： 数据库用户密码
- connect(url, properties): 连接数据库的方法。
-
DriverManager类： 驱动管理器类，用于管理所有注册的驱动程序
- registerDriver(driver) : 注册驱动类对象
- Connection getConnection(url,user,password); 获取连接对象
-
Connection接口： 表示java程序和数据库的连接对象。
- Statement createStatement() ： 创建Statement对象
- PreparedStatement prepareStatement(String sql) 创建PreparedStatement对象
- CallableStatement prepareCall(String sql) 创建CallableStatement对象
-
Statement接口： 用于执行静态的sql语句
- int executeUpdate(String sql) ： 执行静态的更新sql语句（DDL，DML）
- ResultSet executeQuery(String sql) ：执行的静态的查询sql语句（DQL）
-
PreparedStatement接口：用于执行预编译sql语句
- int executeUpdate() ： 执行预编译的更新sql语句（DDL，DML）
-ResultSet executeQuery() ： 执行预编译的查询sql语句（DQL）
- int executeUpdate() ： 执行预编译的更新sql语句（DDL，DML）
-
CallableStatement接口：用于执行存储过程的sql语句（call xxx）
- ResultSet executeQuery() ： 调用存储过程的方法
-
ResultSet接口：用于封装查询出来的数据
- boolean next() ： 将光标移动到下一行
- getXX() : 获取列的值
使用Statement执行DML语句
/**
* 增加数据 (更新和删除只是sql的不同)
*/
public void testInsert(){
Connection conn = null;
Statement statement = null;
try{
conn = JDBCUtil.getConnection(); //获取Connection从前文中有方法
// 3.创建Statement
statement = conn.createStatement();
// 4.准备SQL
String sql = "INSERT INTO student(name,gender) VALUES ('李四','男')";
// 5.执行sql语句
int count = statement.executeUpdate(sql);
System.out.println(count);
}catch(Exception e){
e.printStackTrace();
}finally{
// 6.关闭连接(顺序:后打开的先关闭)
JDBCUtil.close(conn, statement);
}
}
使用Statement执行DQL语句（查询操作）
public void testSelect(){
Connection conn = null;
Statement statement = null;
try{
conn = JDBCUtil.getConnection();
// 3.创建Statement
statement = conn.createStatement();
// 4.准备SQL
String sql = "SELECT * FROM student";
// 5.执行sql语句
ResultSet resultSet = statement.executeQuery(sql);
while(resultSet.next()){
System.out.println("id = " + resultSet.getInt("id"));
System.out.println("name = " + resultSet.getString("name"));
System.out.println("gender = " + resultSet.getString("gender"));
}
}catch(Exception e){
e.printStackTrace();
}finally{
// 6.关闭连接(顺序:后打开的先关闭)
JDBCUtil.close(conn, statement);
}
}
使用PreparedStatement执行sql语句
/**
* 增加 (更新,删除,查询都是相同的)
*/
@Test
public void testInsert() {
Connection conn = null;
PreparedStatement stmt = null;
try {
//1.获取连接
conn = JdbcUtil.getConnection();
//2.准备预编译的sql
String sql = "INSERT INTO student(name,gender) VALUES(?,?)"; //?表示一个参数的占位符
//3.执行预编译sql语句(检查语法)
stmt = conn.prepareStatement(sql);
//4.设置参数值
/**
* 参数一： 参数位置 从1开始
*/
stmt.setString(1, "李四");
stmt.setString(2, "男");
//5.发送参数，执行sql
int count = stmt.executeUpdate();
System.out.println("影响了"+count+"行");
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);
} finally {
JdbcUtil.close(conn, stmt);
}
}
PreparedStatement 与 Statment 的对比
- 语法不同：PreparedStatement可以使用预编译的sql，而Statment只能使用静态的sql
- 效率不同： PreparedStatement可以使用sql缓存区，效率比Statment高
- 安全性不同： PreparedStatement可以有效防止sql注入，而Statment不能防止sql注入。
