JDBC API是一个Java API,能够访问任何类型表列数据,特别是存储在关系数据库中的数据。JDBC表明Java数据库链接。java
JDBC库中所包含的API一般与数据库使用于:mysql
在学习JDBC以前,须要对如下两个编程知识有必定的了解:sql
请确认您已完成如下设置:shell
除上述者外环境配置外,还须要创建一个数据库,为本程项目做为测试使用。假设建立一个数据库:test
,在这个数据库上建立一张表:employees
。数据库
创建一个JDBC应用程序,本教程中以Java链接MySQL为一个示例,分六个步骤进行:编程
在程序中包含数据库编程所需的JDBC类。大多数状况下,使用 import java.sql.*
就足够了,以下所示:数组
//STEP 1. Import required packages import java.sql.*;
须要初始化驱动程序,这样就能够打开与数据库的通讯。如下是代码片断实现这一目标:服务器
//STEP 2: Register JDBC driver Class.forName("com.mysql.jdbc.Driver");
使用DriverManager.getConnection()
方法来建立一个Connection
对象,它表明一个数据库的物理链接,以下所示:yii
//STEP 3: Open a connection // Database credentials static final String USER = "root"; static final String PASS = "pwd123456"; System.out.println("Connecting to database..."); conn = DriverManager.getConnection(DB_URL,USER,PASS);
须要使用一个类型为Statement
或PreparedStatement
的对象,并提交一个SQL语句到数据库执行查询。以下:curl
//STEP 4: Execute a query System.out.println("Creating statement..."); stmt = conn.createStatement(); String sql; sql = "SELECT id, first, last, age FROM Employees"; ResultSet rs = stmt.executeQuery(sql);
若是要执行一个SQL语句:UPDATE
,INSERT
或DELETE
语句,那么须要下面的代码片断:
//STEP 4: Execute a query System.out.println("Creating statement..."); stmt = conn.createStatement(); String sql; sql = "DELETE FROM Employees"; ResultSet rs = stmt.executeUpdate(sql);
这一步中演示如何从数据库中获取查询结果的数据。能够使用适当的ResultSet.getXXX()
方法来检索的数据结果以下:
//STEP 5: Extract data from result set while(rs.next()){ //Retrieve by column name int id = rs.getInt("id"); int age = rs.getInt("age"); String first = rs.getString("first"); String last = rs.getString("last"); //Display values System.out.print("ID: " + id); System.out.print(", Age: " + age); System.out.print(", First: " + first); System.out.println(", Last: " + last); }
在使用JDBC与数据交互操做数据库中的数据后,应该明确地关闭全部的数据库资源以减小资源的浪费,对依赖于JVM的垃圾收集以下:
//STEP 6: Clean-up environment rs.close(); stmt.close(); conn.close();
基于上面的步骤,咱们能够综合示例代码,您能够使用如下代码做为模板来编写JDBC代码。
注意:此示例代码基于环境和数据库环境设置完成的前提下使用。
//STEP 1. Import required packages import java.sql.*; public class FirstExample { // JDBC driver name and database URL static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; static final String DB_URL = "jdbc:mysql://localhost/test"; // Database credentials -- 数据库名和密码本身修改 static final String USER = "username"; static final String PASS = "password"; public static void main(String[] args) { Connection conn = null; Statement stmt = null; try{ //STEP 2: Register JDBC driver Class.forName("com.mysql.jdbc.Driver"); //STEP 3: Open a connection System.out.println("Connecting to database..."); conn = DriverManager.getConnection(DB_URL,USER,PASS); //STEP 4: Execute a query System.out.println("Creating statement..."); stmt = conn.createStatement(); String sql; sql = "SELECT id, first, last, age FROM Employees"; ResultSet rs = stmt.executeQuery(sql); //STEP 5: Extract data from result set while(rs.next()){ //Retrieve by column name int id = rs.getInt("id"); int age = rs.getInt("age"); String first = rs.getString("first"); String last = rs.getString("last"); //Display values System.out.print("ID: " + id); System.out.print(", Age: " + age); System.out.print(", First: " + first); System.out.println(", Last: " + last); } //STEP 6: Clean-up environment rs.close(); stmt.close(); conn.close(); }catch(SQLException se){ //Handle errors for JDBC se.printStackTrace(); }catch(Exception e){ //Handle errors for Class.forName e.printStackTrace(); }finally{ //finally block used to close resources try{ if(stmt!=null) stmt.close(); }catch(SQLException se2){ }// nothing we can do try{ if(conn!=null) conn.close(); }catch(SQLException se){ se.printStackTrace(); }