1566741430592
1555575760234
1555575981203
1566741692804
“JDBC是sun公司提供一套用于数据库操作的接口,java程序员只需要面向这套接口编程即可。 不同的数据库厂商,需要针对这套接口,提供不同实现。不同的实现的集合,即为不同数据库的驱动。 ————面向接口编程 ”
1565969323908
“补充:ODBC(Open Database Connectivity,开放式数据库连接),是微软在Windows平台下推出的。使用者在程序中只需要调用ODBC API,由 ODBC 驱动程序将调用转换成为对特定的数据库的调用请求。 ”
create database testdb;
use testdb;
create table user(
id int primary key auto_increment,
username varchar(20),
password varchar(20),
nickname varchar(20)
);
INSERT INTO `USER` VALUES(null,'zs','123456','老张');
INSERT INTO `USER` VALUES(null,'ls','123456','老李');
INSERT INTO `USER` VALUES(null,'wangwu','123','东方不败');
查询所有的用户, 输出到控制台
image-20201215231645124
image-20201215231740976
image-20201215231823623
按下 alt + insert 搜索依赖,如下:
image-20201215232118694
image-20201215232250288
我们暂时先使用 5.1.49 的版本。
image-20201215232410308
image-20201215232455491
image-20201215233423198
1566136831283
1555576477107
下面我们首先来看看数据库获取连接的几种方式:
image-20201215233800812
// 获取数据库连接的方式一
@Test
public void test01() throws Exception {
//1.提供java.sql.Driver接口实现类的对象
Driver driver = null;
driver = new com.mysql.jdbc.Driver(); // 将要过期的 Driver 方法
//2.提供url,指明具体操作的数据
String url = "jdbc:mysql://localhost:3306/test"; // 指定访问的数据库 jdbc:数据库协议://IP:PORT/DATABASE
//3.提供Properties的对象,指明用户名和密码
Properties info = new Properties();
info.setProperty("user", "root");
info.setProperty("password", "***********");
//4.调用driver的connect(),获取连接
Connection conn = driver.connect(url, info);
System.out.println(conn);
}
上面的示例中,我们写死了 mysql 的 jdbc 驱动,但是有些时候可能是不固定的,也就可能是动态的。这时候,我们可以使用反射机制来创建驱动。
示例如下:
image-20201215234121474
//2.获取数据库连接的方式二
@Test
public void test02() throws Exception {
//1.实例化Driver
//使用反射机制来创建Driver
String className = "com.mysql.jdbc.Driver"; //将要过期的 Driver 方法
Class clazz = Class.forName(className);
Driver driver = (Driver) clazz.newInstance();
//2.提供url,指明具体操作的数据
String url = "jdbc:mysql://localhost:3306/test";
//3.提供Properties的对象,指明用户名和密码
Properties info = new Properties();
info.setProperty("user", "root");
info.setProperty("password", "***********");
//4.调用driver的connect(),获取连接
Connection conn = driver.connect(url, info);
System.out.println(conn);
}
“说明:相较于方式一,这里使用反射实例化Driver,不在代码中体现第三方数据库的API。体现了面向接口编程思想。 ”
上面完成了使用驱动 Driver
来创建数据库连接,但是更多的我们会去使用 DriverManager
来创建,然后再注册驱动。
示例如下:
image-20201217225344531
//3.获取数据库连接的方式三
@Test
public void test03() throws Exception {
//1.数据库连接的4个基本要素:
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "*******************";
String driverName = "com.mysql.jdbc.Driver"; //将要过期的 Driver 方法
//2.实例化Driver
Class clazz = Class.forName(driverName);
Driver driver = (Driver) clazz.newInstance();
//3.注册驱动
DriverManager.registerDriver(driver);
//4.获取连接
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
在上面方式三的基础上,我们可以优化一下,省略一些步骤,因为在 DriverManager
代码的 静态代码块中已经实现,如下:
image-20201019083911829
image-20201019084342694
代码示例如下:
image-20201217230517878
//4.获取数据库连接的方式四
@Test
public void test04() throws Exception {
//1.数据库连接的4个基本要素:
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "****************";
// 可以注释掉上述代码的原因,是因为在mysql的Driver类中声明有:
/**
* Load the initial JDBC drivers by checking the System property
* jdbc.properties and then use the {@code ServiceLoader} mechanism
*/
// static {
// loadInitialDrivers();
// println("JDBC DriverManager initialized");
// }
//4.获取连接
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
在上面的代码中,我们连设置驱动都省略了,这是因为使用的是 mysql,如果是 oracle 可能就不行了,所以设置 驱动 的步骤最好不要省略。
如下:
image-20201019085051363
//4.获取数据库连接的方式四
@Test
public void test04() throws Exception {
//1.数据库连接的4个基本要素:
String url = "jdbc:mysql://localhost:3306/test";
String user = "root";
String password = "Li***********";
//2.加载驱动 (①实例化Driver ②注册驱动)
String driverName = "com.mysql.jdbc.Driver"; //将要过期的 Driver 方法
Class.forName(driverName);
// 可以注释掉上述代码的原因,是因为在mysql的Driver类中声明有:
/**
* Load the initial JDBC drivers by checking the System property
* jdbc.properties and then use the {@code ServiceLoader} mechanism
*/
// static {
// loadInitialDrivers();
// println("JDBC DriverManager initialized");
// }
//4.获取连接
Connection conn = DriverManager.getConnection(url, user, password);
System.out.println(conn);
}
方式四已经写得差不多了,但是我们将账号、密码都写死了,最好的方式是将其设置在配置文件中,通过读取配置文件的信息,来创建数据库连接。
image-20201217232124474
jdbc.properties:
user=root
password=Lijw************
url=jdbc:mysql://localhost:3306/book?rewriteBatchedStatements=true&serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf8&useSSL=false
driverClass=com.mysql.cj.jdbc.Driver
image-20201217232257262
//5.获取数据库连接的方式五(使用配置文件)
@Test
public void test05() throws Exception {
//1.加载配置文件
//1.1 使用类加载器,读取resource文件夹下的 jdbc.properties 配置文件
InputStream is = JDBCTest.class.getClassLoader().getResourceAsStream("jdbc.properties");
//1.2 创建Properties对象,用来加载读取配置字节输入流的信息
Properties pros = new Properties();
pros.load(is);
//2.读取配置信息
String user = pros.getProperty("jdbc.username");
String password = pros.getProperty("jdbc.password");
String url = pros.getProperty("jdbc.url");
String driverClass = pros.getProperty("jdbc.driverClass");
System.out.println("user=" + user + ", password=" + password + ", url=" + url + ", driverClass=" + driverClass);
//3.加载驱动
Class.forName(driverClass);
//4.获取连接
Connection conn = DriverManager.getConnection(url,user,password);
System.out.println(conn);
}
“①实现了代码和数据的分离,如果需要修改配置信息,直接在配置文件中修改,不需要深入代码 ②如果修改了配置信息,省去重新编译的过程。 ”
上面我们已经获取了数据的连接了,那么下面我们实现一个基础的SQL查询,如下:
image-20201217232622479
// 6. 执行SQL查询
@Test
public void test06() throws Exception {
//1.加载配置文件
//1.1 使用类加载器,读取resource文件夹下的 jdbc.properties 配置文件
InputStream is = JDBCTest.class.getClassLoader().getResourceAsStream("jdbc.properties");
//1.2 创建Properties对象,用来加载读取配置字节输入流的信息
Properties pros = new Properties();
pros.load(is);
//2.读取配置信息
String user = pros.getProperty("jdbc.username");
String password = pros.getProperty("jdbc.password");
String url = pros.getProperty("jdbc.url");
String driverClass = pros.getProperty("jdbc.driverClass");
//3.加载驱动
Class.forName(driverClass);
//4.获取连接
Connection conn = DriverManager.getConnection(url,user,password);
System.out.println(conn);
//5.创建执行sql语句对象
Statement statement = conn.createStatement();
//6.执行sql,处理结果
String sql = "select * from user";
ResultSet resultSet = statement.executeQuery(sql);
while (resultSet.next()) {
System.out.println(resultSet.getObject(1));
System.out.println(resultSet.getObject(2));
System.out.println(resultSet.getObject(3));
System.out.println(resultSet.getObject(4));
}
//7.关闭资源
resultSet.close();
statement .close();
conn.close();
}