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