JDBC简述
Java如何连接数据库呢?
答案是:Java使用JDBC连接数据库。
那么JDBC又是什么?
Java数据库连接(Java Database Connectivity,简称JDBC)是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口,提供了诸如查询和更新数据库中数据的方法。
对于不同的数据库,我们需要知道不同数据库对外提供的系统 API,这就影响了我们程序的扩展和跨平台的实现。JDBC为Java开发者使用数据库提供了统一的编程接口,它由一组java类和接口组成.是java程序与数据库系统通信的标准APl。 JDBC API使得开发人员可以使用纯 java 的方式来连接数据库,并执行操作。
对于我们自己写的程序这一端,接口是统一的,而对于不同数据库产品的连接是通过不同的 JDBC 类库实现的。
MySQL编写基础
使用JDBC访问数据库的流程
- 加载JDBC驱动
- 连接数据库
- 执行SQL查询
- 从结果集中提取数据
- 处理结果集
- 清理环境,关闭所有的数据库资源,释放内存
完整的测试代码:
import java.sql.*;
public class JdbcTest {
// JDBC驱动器名称和数据库地址
static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
// 数据库的名称为EXAMPLE
static final String DB_URL = "jdbc:mysql://localhost/EXAMPLE";
// 数据库用户和密码
static final String USER = "root";
static final String PASS = "";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try{
//注册JDBC 驱动程序
Class.forName("com.mysql.jdbc.Driver");
//打开连接
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);
//执行查询
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id, name, age FROM Students";
ResultSet rs = stmt.executeQuery(sql);
//得到和处理结果集
while(rs.next()){
//检索
int id = rs.getInt("id");
int age = rs.getInt("age");
String name = rs.getString("name");
//显示
System.out.print("ID: " + id);
System.out.print(", Age: " + age);
System.out.print(", Name: " + name);
System.out.println();
}
//清理环境
rs.close();
stmt.close();
conn.close();
}catch(SQLException se){
// JDBC 操作错误
se.printStackTrace();
}catch(Exception e){
// Class.forName 错误
e.printStackTrace();
}finally{
//这里一般用来关闭资源的
try{
if(stmt!=null)
stmt.close();
}catch(SQLException se2){
}
try{
if(conn!=null)
conn.close();
}catch(SQLException se){
se.printStackTrace();
}
}
System.out.println("Goodbye!");
}
}
注:上述测试代码基于已经使用MySQL建立了一个名为EXAMPLE的数据库和一张名为Students表的基础上。
步骤分解
导入JDBC驱动
只有拥有了驱动程序我们才可以注册驱动程序完成连接的其他步骤。
根据自己所使用的数据库类型和版本下载对应的驱动(本人数据库使用MySQL),MySQL的驱动包,其他请自行Google。
在Eclipse建立好的工程中导入下载好的MySQL驱动包
注册JDBC驱动程序
这一步会导致JVM加载所需的驱动程序实现到内存中,因此它可以实现JDBC请求。
-
注册一个驱动程序中最常用的方法是使用Java的Class.forName()方法来动态加载驱动程序的类文件到内存中,它会自动将其注册。不同的数据库有不同的装载方法。以下是装在MySQL驱动的代码:
try { Class.forName("com.mysql.jdbc.Driver"); } catch(ClassNotFoundException ex) { System.out.println("Error: unable to load driver class!"); System.exit(1); }
-
数据库URL制定:创建具有正确格式的地址,指向到要连接的数据库。
getConnection(String url) getConnection(String url, Properties prop) getConnection(String url, String user, String password) Mysql的URL是jdbc:mysql://hostname/ databaseName
-
创建连接对象:最后,代码调用DriverManager对象的getConnection()方法来建立实际的数据库连接。
import java.sql.*; public class JdbcTest { // JDBC 驱动器的名称和数据库地址 static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; static final String DB_URL = "jdbc:mysql://localhost/EXAMPLE"; static final String USER = "root"; static final String PASS = ""; public static void main(String[] args) { Connection conn = null; PreparedStatement stmt = null; //注册 JDBC 驱动器 Class.forName("com.mysql.jdbc.Driver"); //打开连接 System.out.println("Connecting to database..."); conn = DriverManager.getConnection(DB_URL,USER,PASS); System.out.println("Connecting Successful..."); } }
执行SQL语句
Statement接口用于执行静态SQL语句并返回它所生成结果的对象。
三种Statement类:
Statement: 由createStatement创建,用于发送简单的SQL语句。(不带参数的)
PreparedStatement:继承自Statement接口,由prepareStatement创建,用于发送含有一个或多个输入参数的sql语句。PreparedStatement对象,会进行预编译,比Statement对象的效率更高,并且可以防止SQL注入。我们一般都使用PreparedStatement。
CallableStatement: 继承自PreparedStatement,由方法prePareCall创建,用于调用存储过程。
常用的Statement方法:
- execute():运行语句,返回是否有结果集。
- executeQuery():运行select语句,返回ResultSet结果集。
- executeUpdate():运行insert/update/delete操作,返回更新的行数。
提取并处理查询结果
Statement执行SQL语句时,返回ResultSet结果集。
ResultSet提供的检索不同类型字段的方法,常用的有:
- getString():获得在数据库里varchar、char等数据类型的对象。
- getFloat():获得在数据库里Float类型的对象。
- getDate():获得在数据库里Date类型的数据。
- getBoolean():获得在数据库里面Boolean类型的数据。
关闭数据库连接,释放内存。
关闭服务的顺序和连接刚好相反。先清理查询所占用的内存,再关闭数据库连接。