電子發燒友App
創建一個以JDBC連接數據庫的程序，包含7個步驟：
1、加載JDBC驅動程序：
在連接數據庫之前，首先要加載想要連接的數據庫的驅動到JVM（Java虛擬機）， 這通過java.lang.Class類的靜態方法forName（String className）實現。
例如：
try{
//加載MySql的驅動類
Class.forName（“com.mysql.jdbc.Driver”） ;
}catch（ClassNotFoundException e）{
System.out.println（“找不到驅動程序類 ，加載驅動失敗！”）;
e.printStackTrace（） ;
}
成功加載后，會將Driver類的實例注冊到DriverManager類中。
不同數據庫廠商的驅動類名不同
Oracle10g：oracle.jdbc.driver.OracleDriver
MySQL5：com.mysql.jdbc.Driver
SQLServer2005：com.microsoft.sqlserver.jdbc.SQLServerDriver
2、提供JDBC連接的URL
?連接URL定義了連接數據庫時的協議、子協議、數據源標識。
?書寫形式：協議：子協議：數據源標識
協議：在JDBC中總是以jdbc開始
子協議：是橋連接的驅動程序或是數據庫管理系統名稱。
數據源標識：標記找到數據庫來源的地址與連接端口。
例如：（MySql的連接URL）
jdbc:mysql://localhost:3306/test？ ;
不同數據庫產品的連接URL不同
Oracle10g：jdbc:oracle:thin：@主機名：端口：數據庫SID
jdbc:oracle:thin：@localhost:1521:ORCL
MySQL5：jdbc:mysql://主機名：端口/數據庫名
jdbc:mysql://localhost:3306/test
SQLServer2005：jdbc:sqlserver://主機名：端口：DatabaseName=庫名
jdbc:sqlserver://localhost:1433:DatabaseName=BookDB
數據庫的用戶名和密碼
3、創建數據庫的連接
?要連接數據庫，需要向java.sql.DriverManager請求并獲得Connection對象，該對象就代表一個數據庫的連接。
?使用DriverManager的getConnectin（String url ， String username ， String password ）方法傳入指定的欲連接的數據庫的路徑、數據庫的用戶名和 密碼來獲得。
例如：
//連接MySql數據庫，用戶名和密碼都是root
String url = “jdbc:mysql://localhost:3306/test” ;
String username = “root” ;
String password = “root” ;
try{
Connection con =
DriverManager.getConnection（url ， username ， password ） ;
}catch（SQLException se）{
System.out.println（“數據庫連接失敗！”）;
se.printStackTrace（） ;
}
4、創建一個Statement
?要執行SQL語句，必須獲得java.sql.Statement實例，Statement實例分為以下3 種類型：
1、執行靜態SQL語句。通常通過Statement實例實現。
2、執行動態SQL語句。通常通過PreparedStatement實例實現。
3、執行數據庫存儲過程。通常通過CallableStatement實例實現。
具體的實現方式：
Statement stmt = con.createStatement（） ;
PreparedStatement pstmt = con.prepareStatement（sql） ;
CallableStatement cstmt =
con.prepareCall（“{CALL demoSp（？ ， ？）}”） ;
5、執行SQL語句
Statement接口提供了三種執行SQL語句的方法：executeQuery 、executeUpdate 和execute
1、ResultSet executeQuery（String sqlString）：執行查詢數據庫的SQL語句，返回一個結果集（ResultSet）對象。
2、int executeUpdate（String sqlString）：用于執行INSERT、UPDATE或 DELETE語句以及SQL DDL語句，如：CREATE TABLE和DROP TABLE等
3、execute（sqlString）：用于執行返回多個結果集、多個更新計數或二者組合的語句。
具體實現的代碼：
ResultSet rs = stmt.executeQuery（“SELECT * FROM 。。。”） ;
int rows = stmt.executeUpdate（“INSERT INTO 。。。”） ;
boolean flag = stmt.execute（String sql） ;
6、處理結果
兩種情況：
1、執行更新返回的是本次操作影響到的記錄數。
2、執行查詢返回的結果是一個ResultSet對象。
? ResultSet包含符合SQL語句中條件的所有行，并且它通過一套get方法提供了對這些
行中數據的訪問。
? 使用結果集（ResultSet）對象的訪問方法獲取數據：
while（rs.next（））{
String name = rs.getString（“name”） ;
String pass = rs.getString（1） ; // 此方法比較高效
}
（列是從左到右編號的，并且從列1開始）
7、關閉JDBC對象
操作完成以后要把所有使用的JDBC對象全都關閉，以釋放JDBC資源，關閉順序和聲明順序相反：
1、關閉記錄集
2、關閉聲明
3、關閉連接對象
if（rs ！= null）{ // 關閉記錄集
try{
rs.close（） ;
}catch（SQLException e）{
e.printStackTrace（） ;
}
}
if（stmt ！= null）{ // 關閉聲明
try{
stmt.close（） ;
}catch（SQLException e）{
e.printStackTrace（） ;
}
}
if（conn ！= null）{ // 關閉連接對象
try{
conn.close（） ;
}catch（SQLException e）{
e.printStackTrace（） ;
}
}
8、實例：JdbcUtils
我將他們封裝到一個類中，并進行了測試。代碼中解釋很詳細，我就不再進行解釋了。
package com.jdbc.dbutils;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class JdbcUtils {
/**
* 數據庫的用戶名
*/
private final String USER = “root”;
/**
* 數據庫的密碼
*/
private final String PASSWORD = “123456”;
/**
* 數據庫的驅動信息
*/
private final String DRIVER = “com.mysql.jdbc.Driver”;
/**
* 訪問數據庫的地址
*/
private final String URL = “jdbc:mysql://localhost:3306/test”;
/**
* 數據庫的連接
*/
Connection connection;
/**
* sql語句的執行對象
*/
PreparedStatement preparedStatement;
/**
* 查詢返回的結果集合
*/
ResultSet resultSet;
public JdbcUtils（） {
try {
Class.forName（DRIVER）;
System.out.println（“注冊驅動成功”）;
} catch （ClassNotFoundException e） {
e.printStackTrace（）;
}
}
/**
* 連接數據庫
*
* @return 數據庫的連接對象
*/
public Connection getConnection（） {
try {
connection = DriverManager.getConnection（URL， USER， PASSWORD）;
} catch （SQLException e） {
e.printStackTrace（）;
}
return connection;
}
/**
* 完成對數據庫的表的添加刪除和修改的操作
*
* @param sql
* @param params
* @return
* @throws SQLException
*/
public boolean updateByPrepareStatement（String sql， List《Object> params）
throws SQLException {
boolean flag = false;
int result = -1;// 表示當用戶執行添加刪除和修改的時候所影響數據庫的行數
// 創建一個 PreparedStatement 對象來將參數化的 sql 語句發送到數據庫。
preparedStatement = connection.prepareStatement（sql）;
int index = 1;
if （params ！= null && ！params.isEmpty（）） {
for （Object object ： params） {
// 使用給定對象設置指定參數的值。index從1開始
preparedStatement.setObject（index++， object）;
}
}
// 在此 PreparedStatement 對象中執行 SQL 語句，該語句必須是一個 SQL 數據操作語言語句，比如
// INSERT、UPDATE 或 DELETE 語句
result = preparedStatement.executeUpdate（）;
flag = result > 0 ？ true ： false;
return flag;
}
/**
* 查詢返回單條記錄
*
* @param sql
* @param params
* @return
* @throws SQLException
*/
public Map
throws SQLException {
Map
int index = 1;
// 創建一個 PreparedStatement 對象來將參數化的 sql 語句發送到數據庫。
preparedStatement = connection.prepareStatement（sql）;
if （params ！= null && ！params.isEmpty（）） {
for （Object object ： params） {
// 使用給定對象設置指定參數的值。index從1開始
preparedStatement.setObject（index++， object）;
}
}
// 在此 PreparedStatement 對象中執行 SQL 查詢，并返回該查詢生成的 ResultSet 對象。
resultSet = preparedStatement.executeQuery（）;
// 獲取此 ResultSet 對象的列的編號、類型和屬性。
ResultSetMetaData metaData = resultSet.getMetaData（）;
int col_len = metaData.getColumnCount（）;
while （resultSet.next（）） {
for （int i = 0; i
// sql數據庫列的下標是從1開始的
String col_name = metaData.getColumnName（i + 1）;
Object col_value = resultSet.getObject（col_name）;
if （col_value == null） {
col_value = “”;
}
map.put（col_name， col_value）;
}
}
return map;
}
public List
List
List
int index = 1;
// 創建一個 PreparedStatement 對象來將參數化的 sql 語句發送到數據庫。
preparedStatement = connection.prepareStatement（sql）;
if （params ！= null && ！params.isEmpty（）） {
for （Object object ： params） {
// 使用給定對象設置指定參數的值。index從1開始
preparedStatement.setObject（index++， object）;
}
}
// 在此 PreparedStatement 對象中執行 SQL 查詢，并返回該查詢生成的 ResultSet 對象。
resultSet = preparedStatement.executeQuery（）;
// 獲取此 ResultSet 對象的列的編號、類型和屬性。
ResultSetMetaData metaData = resultSet.getMetaData（）;
int col_len = metaData.getColumnCount（）;
while （resultSet.next（）） {
Map
for （int i = 0; i < col_len; i++） {
// sql數據庫列的下標是從1開始的
String col_name = metaData.getColumnName（i + 1）;
Object col_value = resultSet.getObject（col_name）;
if （col_value == null） {
col_value = “”;
}
map.put（col_name， col_value）;
}
list.add（map）;
}
return list;
}
/**
* 關閉數據庫
*
* @throws SQLException
*/
public void releaseConn（） throws SQLException {
if （resultSet ！= null） {
resultSet.close（）;
}
if （preparedStatement ！= null） {
preparedStatement.close（）;
}
if （connection ！= null） {
connection.close（）;
}
}
static JdbcUtils jdbcUtils;
public static void main（String［］ args） throws SQLException {
jdbcUtils = new JdbcUtils（）;
jdbcUtils.getConnection（）;
// insert（）;
// update（）;
// query（）;
Morequery（）;
}
private static void query（） throws SQLException {
String sql = “select * from userinfo where pwd = ？ ”;
List
params.add（“123”）;
Map
System.out.println（map）;
}
private static void Morequery（） throws SQLException {
String sql = “select * from userinfo ”;
List
System.out.println（map）;
}
/**
* 更新數據庫內容
*
* @throws SQLException
*/
private static void update（） throws SQLException {
String sql = “update userinfo set username =？ where id=2”;
List
params.add（“liumr”）;
jdbcUtils.updateByPrepareStatement（sql， params）;
}
/**
* 增加數據
*
* @throws SQLException
*/
private static void insert（） throws SQLException {
String sql = “insert userinfo （username，pwd） values （？，？）”;
List
params.add（“liugx”）;
params.add（“456”）;
jdbcUtils.updateByPrepareStatement（sql， params）;
}
}
工商網監
評論