java JDBC連線資料庫步驟及程式碼
阿新 • • 發佈：2018-12-22
JDBC連線資料庫，包含7個步驟
（1）載入JDBC驅動程式
在連線資料庫之前，首先要載入想要連線的資料庫的驅動到JVM（Java虛擬機器）， 這通過java.lang.Class類的靜態方法forName(String className)實現，成功載入後，會將Driver類的例項註冊到DriverManager類中。
程式碼如下：
static{ try { Class.forName("com.mysql.jdbc.Driver");//載入資料庫驅動 } catch (ClassNotFoundException e) { e.printStackTrace(); } }
（2）提供JDBC連線的URL
書寫形式：協議：子協議：資料來源標識 。 其中：
協議：在JDBC中總是以jdbc開始 。子協議：是橋連線的驅動程式或是資料庫管理系統名稱。 資料來源標識：標記找到資料庫來源的地址與連線埠。
程式碼如下：
//連線MySql資料庫，使用者名稱和密碼都是root String url = "jdbc:mysql://localhost:3306/test" ; String username = "root" ; String password = "root" ;
（3）建立資料庫的連線
程式碼如下：
public static Connection getConn(){ Connection conn = null; try { conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root","root");//連線資料庫 } catch(SQLException e){ e.printStackTrace(); } return conn; }
（4）建立一個Statement
要執行SQL語句，必須獲得java.sql.Statement例項，Statement例項分為以下3 種類型：
- 執行靜態SQL語句。通常通過Statement例項實現。
- 執行動態SQL語句。通常通過PreparedStatement例項實現。
- 執行資料庫儲存過程。通常通過CallableStatement例項實現。
程式碼如下：
public static Statement getStmt(Connection conn){
Statement stmt = null;
try {
stmt = conn.createStatement();
} catch (SQLException e) {
e.printStackTrace();
}
return stmt;
}（5）執行SQL語句
Statement介面提供了三種執行SQL語句的方法：executeQuery 、executeUpdate 和execute
- ResultSet executeQuery(String sqlString)：執行查詢資料庫的SQL語句 ，返回一個結果集（ResultSet）物件。
- int executeUpdate(String sqlString)：用於執行INSERT、UPDATE或 DELETE語句以及SQL DDL語句，如：CREATE TABLE和DROP TABLE等
- execute(sqlString):用於執行返回多個結果集、多個更新計數或二者組合的 語句。
程式碼如下：
public static ResultSet executeQuery(Statement stmt,String sql){
ResultSet rs = null;
try {
rs = stmt.executeQuery(sql);
} catch (SQLException e) {
e.printStackTrace();
}
return rs;
}
（6）處理結果
兩種情況：
- 執行更新返回的是本次操作影響到的記錄數。
- 執行查詢返回的結果是一個ResultSet物件。
ResultSet包含符合SQL語句中條件的所有行，並且它通過一套get方法提供了對這些行中資料的訪問。
使用結果集（ResultSet）物件的訪問方法獲取資料，程式碼如下：
while(rs.next()){
String name = rs.getString("name") ;
String pass = rs.getString(1) ; // 此方法比較高效
}（7）關閉JDBC物件
操作完成以後要把所有使用的JDBC物件全都關閉，以釋放JDBC資源，關閉順序和宣告順序相反：
- 關閉記錄集
- 關閉宣告
- 關閉連線物件
程式碼如下：
//關閉結果集
public static void closeRs(ResultSet rs){
try {
if(rs != null ){
rs.close();
rs = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
//關閉執行方法
public static void closeStmt(Statement stmt){
try {
if(stmt != null ){
stmt.close();
stmt = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
//關閉連線
public static void closeConn(Connection conn){
try {
if(conn != null ){
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}JDBC連線資料庫工具類程式碼
package com.njau.allnetitem;
import java.sql.*;
public class DB {
static{
try {
Class.forName("com.mysql.jdbc.Driver");//載入資料庫驅動
}
catch (ClassNotFoundException e) {
e.printStackTrace();
}
}
private DB() {}
public static Connection getConn(){
Connection conn = null;
try {
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db_baima", "root","123456");//連線資料庫
}
catch(SQLException e){
e.printStackTrace();
}
return conn;
}
public static void closeConn(Connection conn){
try {
if(conn != null ){
conn.close();
conn = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static Statement getStmt(Connection conn){
Statement stmt = null;
try {
stmt = conn.createStatement();
} catch (SQLException e) {
e.printStackTrace();
}
return stmt;
}
public static PreparedStatement getPStmt(Connection conn,String sql){
PreparedStatement pstmt = null;
try {
pstmt = conn.prepareStatement(sql);
} catch (SQLException e) {
e.printStackTrace();
}
return pstmt;
}
public static void closeStmt(Statement stmt){
try {
if(stmt != null ){
stmt.close();
stmt = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static ResultSet executeQuery(Statement stmt,String sql){
ResultSet rs = null;
try {
rs = stmt.executeQuery(sql);
} catch (SQLException e) {
e.printStackTrace();
}
return rs;
}
public static void closeRs(ResultSet rs){
try {
if(rs != null ){
rs.close();
rs = null;
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static ResultSet executeQuery(Connection conn,String sql){//過載
ResultSet rs = null;
try {
rs = conn.createStatement().executeQuery(sql);
} catch (SQLException e) {
e.printStackTrace();
}
return rs;
}
}
工具類使用說明程式碼
//插入資料
public static void saveinfo(Object[] data) throws ParseException{
Connection conn = null;
PreparedStatement pstmt = null;
try {
conn= DB.getConn();
String sql = "insert into information value (null,?,?,?,?,?,?,?) ";
pstmt = DB.getPStmt(conn, sql);
pstmt.setString(1,(String) data[0]);
pstmt.setString(2, (String) data[1]);
pstmt.setString(3,(String) data[2]);
pstmt.setString(4,(String) data[3]);
pstmt.setString(5,(String) data[4]);
pstmt.setString(6,(String) data[5]);
pstmt.setTimestamp(7 ,(Timestamp)data[6]);
pstmt.executeUpdate();
}
catch (SQLException e) {
e.printStackTrace();
}
finally{
DB.closeStmt(pstmt);
DB.closeConn(conn);
}
}參考：
http://www.cnblogs.com/hongten/archive/2011/03/29/1998311.html
表示感謝！！