- 创建连接
- 执行sql
- 检索sql执行结果
- 关闭连接
一、创建连接的两种方式
- 使用DriveManger获取连接
Connection connection = DriverManager.getConnection("url", "username", "password");
- 使用DataSource获取连接
DataSource这个接口是JDBC规范2.0可选包中引入的API。注意:JDBC规范2.0中只定义了接口,具体的实现由数据库厂商驱动完成。一些主流的数据库连接池也提供了相应的实现。
相对于DriveManger获数据库连接的方式优势在于提供了更多的底层数据源相关细节。而且对于应用来说,不需要关注JDBC驱动的实现。一个DataSource对象的属性被设置后,它就代表一个特定的数据源。当DataSource实例的getConnection()方法被调用后,DataSource实例就会返回一个与数据源建立连接的Connection对象。在应用程序中修改DataSource对象的属性后,就可以通过DataSouece对象获取指向不同数据源的Connection对象。同样,数据源的具体实现修改后,不需要修改应用程序代码。
节选自MyBatis3 源码深度解析 p14
MyBatis框架对DataSource的实现可以查阅相关源码,目录包为org.apache.ibatis.datasource
MyBatis的其中一种实现
DataSource dataSource = new UnpooledDataSource("driver","url","username","password");
二、执行sql语句
创建数据库连接之后,我们可以获得Connection对象,通过对Connection对象设置事务属性,使用Connection接口中提供的方法可以创建Statement、PreparedStatement、CallableStatement对象。
Statement、PrepareStatement、CallableStatement三者的区别
Statement接口可以理解为sql的执行器,不同的查询类型提供了不同的查询方法。
示例:
Statement statement = Connection.createStatement();
ResultSet result = statement.executeQuery("select * from user");
三、检索sql执行结果
statement执行完毕后会返回ResultSet对象,我们可以遍历ResultSet对象来解析结果集。ResultSet对象提供了多种getXXX()方法以应对不同的数据类型。
四、关闭连接
执行完操作后需要对Statement、Connection对象关闭连接。
示例代码:
public static void main(String[] args) throws SQLException, ClassNotFoundException {
//加载驱动
Class.forName("com.mysql.jdbc.Driver");
//DriverManager根据url可以在依赖中搜索相关驱动,前提是项目要引用到驱动包
Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/fertilizer?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&useSSL=false"
, "root", "root");
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("select * from user");
ResultSetMetaData metaData = resultSet.getMetaData();
int columnCount = metaData.getColumnCount();
while (resultSet.next()) {
//注意,这里获取列明称时,从1开始
for (int i = 1; i < columnCount; i++) {
String columnName = metaData.getColumnName(i);
String value = resultSet.getString(columnName);
System.out.println(String.format("%s:%s",columnName,value));
System.out.println("---------------------------------");
}
}
statement.close();
connection.close();
}