[置頂] 【JDBC】JDBC入門匯總及范例講解
來源：程序員人生 發布時間：2015-08-03 08:33:41 閱讀次數：4095次
林炳文Evankaka原創作品。轉載請注明出處http://blog.csdn.net/evankaka
1、JDBC是甚么?
JDBC API是1個Java API，可以訪問任何類型表列數據，特別是存儲在關系數據庫中的數據。JDBC代表Java數據庫連接。
JDBC庫中所包括的API任務通常與數據庫使用：
連接到數據庫
創建SQL或MySQL語句
在數據庫中履行SQL或MySQL查詢
查看和修改記錄
2、使用JDBC要有甚么條件呢？
3、JDBC技術的原理
我們知道，數據庫是有各種類型的，不同的廠商生產的數據庫標格和規范是不同的，這時候候，如果我們用JAVA代碼來發送SQL語句，就要根據不同的數據庫來寫1套又1套的操作代碼，這對程序開發者的開發本錢是10分巨大的，所以，SUN公司在開發JDBC技術的時候，規定了1套標準接口，數據庫產商都必須提供1個驅動來實現這套接口，那末，只要程序開發者在開發時使用了該數據庫的驅動，就用1致的方法來開發了，而不需自己寫1套有1套的代碼去適應不同的數據庫。
4、JDBC中的核心API
|- Driver : 驅動程序類實現的接口。
|-Connection connect(String url, Properties info) --用于連接數據庫，得到連接對象
Properties 里需要設置的參數：
url： 數據庫連接的URL字符串。協議+數據庫子協議+主機+端口+數據庫
user： 數據庫用戶名
password： 用戶的密碼
|-Connection : 與數據庫連接的接口
|- Statement createStatement() --創建Statement對象，用于發送sql語句
|- PreparedStatement prepareStatement(String sql) -創建PreparedStatement對象，用于發送預編譯的sql語句
|-CallableStatement prepareCall(String sql) --創建CallableStatement對象，用于調用存儲進程。
|-Statement： 用于履行靜態sql語句
|-int executeUpdate(String sql) --履行更新操作（DDL+DML）
|-ResultSet executeQuery(String sql) --履行查詢操作(DQL)
|- PreparedStatement： 用于履行預編譯的sql語句
|- int executeUpdate() -- 履行更新操作
|- ResultSet executeQuery() -- 履行查詢操作
|- CallableStatement： 用于履行存儲進程的sql
|- ResultSet executeQuery() --調用存儲進程
|- ResultSet： 結果集。用于封裝數據庫的查詢后的數據
|- boolean next() --將記錄光標移動到下1行
|- Object getObject(int columnIndex) -- 得到字段上的值
5、創建JDBC利用程序步驟
1、導入包
這需要你有軟件包包括了數據庫編程所需的JDBC類。大多數情況下，使用import java.sql.* 就足夠了，以下所示
import java.sql.*;
2、注冊jdbc驅動程序這需要初始化驅動程序，這樣就能夠打開與數據庫的通訊信道。以下是代碼片斷實現這1目標：
Class.forName("com.mysql.jdbc.Driver");
3、打開1個連接這需要使用DriverManager.getConnection()方法來創建1個Connection對象，它代表1個物理連接的數據庫，以下所示：
static final String USER = "username";
static final String PASS = "password";
System.out.println("Connecting to database...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);
4、履行1個查詢
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "SELECT id, first, last, age FROM Employees";
ResultSet rs = stmt.executeQuery(sql);
如果有1個SQL UPDATE，INSERT或DELETE語句，那末需要下面的代碼片斷：
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql;
sql = "DELETE FROM Employees";
ResultSet rs = stmt.executeUpdate(sql);
5、從結果中提取數據
這1步是必須的情況下，從數據庫中獲得數據。可使用適當的ResultSet.getXXX()方法來檢索的數據結果以下：
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);
}
6、清算環境
應當明確地關閉所有的數據庫資源，對依賴于JVM的垃圾搜集以下：
rs.close();
stmt.close();
conn.close();
6、使用范例
下面的例子，簡單的使用了創建數據表、插入數據、查找數據的功能：
工程目錄以下：
記得加相應的包：mysql-connector-java⑸.1.22-bin.jar
package com.mucfc;
import java.sql.*;
public class JdbcTest {
//定義
數據庫驅動程序
private static final String DBDRIVER="com.mysql.jdbc.Driver";
//
數據庫連接地址
private static final String DBURL="jdbc:mysql://localhost:3306/school";//school表示
數據庫
//
數據庫用戶名
private static final String DBUSER="root";
//電腦上的
數據庫密碼
private static final String DBPASS="christmas258@";
public void testDDL(){
try {
//1.注冊驅動
Class.forName(DBDRIVER);
//2.獲得連接
Connection conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS);
//3.創建Statement對象
Statement stmt = conn.createStatement();
//4.準備sql語句
String sql ="CREATE TABLE student(sid INT PRIMARY KEY,sname VARCHAR(20),age INT)";
//5.通過statement對象發送sql語句,返回履行結果
int count = stmt.executeUpdate(sql);
System.out.println("CREATE TABLE student......");
//6.打印履行結果
System.out.println("影響了"+count+"條記錄");
//履行插入操作
System.out.println("Inserting records into the table...");
sql = "INSERT INTO student " +
"VALUES (100, '小文', 18)";
stmt.executeUpdate(sql);
sql = "INSERT INTO student " +
"VALUES (101, '大林', 25)";
stmt.executeUpdate(sql);
sql = "INSERT INTO student " +
"VALUES (102, '阿白', 30)";
stmt.executeUpdate(sql);
sql = "INSERT INTO student " +
"VALUES(103, '小小', 28)";
stmt.executeUpdate(sql);
System.out.println("Inserted records into the table...");
//履行查找操作
sql = "SELECT* FROM student";
System.out.println("SELECT records FROM the table...");
ResultSet rs = stmt.executeQuery(sql);
//輸出查找結果
while(rs.next()){
//先獲得數據
int sid = rs.getInt("sid");
String sname = rs.getString("sname");
int age = rs.getInt("age");
//打印結果
System.out.print("sid: " + sid);
System.out.print(" sname: " +sname);
System.out.println(" age: " + age);
}
rs.close();
//7.關閉資源
try {
if(stmt!=null)
{
stmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
try {
if(conn!=null)
{
conn.close();
}
} catch (Exception e) {
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
JdbcTest jdbcTest=new JdbcTest();
jdbcTest.testDDL();
}
}
從上面的例子可以看到，這個進程還是比較簡單的，這里要注意的是，school數據庫要存在，如果沒有的話，自己在MySql按以下語句創建1個：
CREATE DATABASE school;
如果要進行DQL與DDL操作，都可以把SQL語句寫好，然后調用statement的executlUpdate方法來給數據庫履行SQL語句，這個方法返回1個整數值，表示數據庫中有多少行遭到了影響。如果我們不改變上述的程序，想要再向數據庫發出SQL語句，那末又要寫1個程序來再次連接，操作完后又要關閉statement對象 和connection對象，這是10分繁瑣的。所以，我們1般把連接進程和釋放對象的進程抽取到1個工具類中。工具類中的代碼以下：package com.mucfc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class SqlDB {
//定義
數據庫驅動程序
private static final String DBDRIVER="com.mysql.jdbc.Driver";
//
數據庫連接地址
private static final String DBURL="jdbc:mysql://localhost:3306/school";//school表示
數據庫
//
數據庫用戶名
private static final String DBUSER="root";
//電腦上的
數據庫密碼
private static final String DBPASS="christmas258@";
public static Connection getconnection() {
Connection conn = null;
try {
// 1.注冊驅動
Class.forName(DBDRIVER);
//2.獲得連接
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS);
//3.創建Statement對象
Statement stmt = conn.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
//7.關閉資源
public static void close(Statement statement, Connection connection) {
{
try {
if (statement != null)
statement.close();
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
public void CreateTableTest(){
//獲得連接
Connection cnn2=SqlDB.getconnection();
Statement statement = null;
try {
statement = cnn2.createStatement();
} catch (SQLException e) {
e.printStackTrace();
}
//準備SQL語句
String sql ="CREATE TABLE student(sid INT PRIMARY KEY,sname VARCHAR(20),age INT)";
System.out.println("CREATE TABLE student......");
//調用executeQuery履行查詢語
try {
statement.executeUpdate(sql);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
SqlDB.close(statement,cnn2);
}
public void InsertTest(){
//獲得連接
Connection cnn2=SqlDB.getconnection();
Statement statement=null;
try {
statement = cnn2.createStatement();
} catch (SQLException e) {
e.printStackTrace();
}
//履行插入操作
System.out.println("Inserting records into the table...");
String sql = "INSERT INTO student " +
"VALUES (100, '小文', 18)";
try {
statement.executeUpdate(sql);
} catch (SQLException e1) {
e1.printStackTrace();
}
sql = "INSERT INTO student " +
"VALUES (101, '大林', 25)";
try {
statement.executeUpdate(sql);
} catch (SQLException e1) {
e1.printStackTrace();
}
sql = "INSERT INTO student " +
"VALUES (102, '阿白', 30)";
try {
statement.executeUpdate(sql);
} catch (SQLException e1) {
e1.printStackTrace();
}
sql = "INSERT INTO student " +
"VALUES(103, '小小', 28)";
try {
statement.executeUpdate(sql);
} catch (SQLException e1) {
e1.printStackTrace();
}
System.out.println("Inserted records into the table...");
SqlDB.close(statement, cnn2);
}
public void SelectTest(){
//獲得連接
Connection cnn2=SqlDB.getconnection();
Statement statement=null;
try {
statement = cnn2.createStatement();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//準備SQL語句
String sql = "select * from student";
//調用executeQuery履行查詢語句
ResultSet res = null;
try {
res = statement.executeQuery(sql);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
//查詢結束后res會指向表頭，想要獲得數據必須不斷地指向查詢結果的下1行，當沒有下1行數據時，返回0.
System.out.println("select records from the table...");
try {
while(res.next())
{
//先獲得數據
int sid = res.getInt("sid");
String sname = res.getString("sname");
int age = res.getInt("age");
//打印結果
System.out.print("sid: " + sid);
System.out.print(" sname: " +sname);
System.out.println(" age: " + age);
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
res.close();
} catch (SQLException e) {
e.printStackTrace();
}
SqlDB.close(statement, cnn2);
}
然后就是調用： JdbcTest jdbcTest=new JdbcTest();
jdbcTest.CreateTableTest();
jdbcTest.InsertTest();
jdbcTest.SelectTest();
結果：
發現代碼量反而增多了。。。。看來還優化得不好
想辦法看是不是能把創建數據庫、插入數據、查找數據都入在SqlDB當中，然后我們需要時只要傳入相應的參數便可，下面就來對SqlDB來進行改造：
把創建數據庫、插入和查找都放到1個文件中去
package com.mucfc;
import java.sql.*;
/**
*
數據庫操作類的1個簡單封裝
* @author 林炳文
* @time 2015.4.30
*/
public class SqlDB {
// 定義
數據庫驅動程序
private static final String DBDRIVER = "com.mysql.jdbc.Driver";
//
數據庫連接地址
private static final String DBURL = "jdbc:mysql://localhost:3306/school";// school表示
數據庫
//
數據庫用戶名
private static final String DBUSER = "root";
// 電腦上的
數據庫密碼
private static final String DBPASS = "christmas258@";
/**
* 創建
數據庫連接1初始操作
*
* @return
數據庫連接的句柄
*/
public static Connection getconnection() {
Connection conn = null;
try {
// 1.注冊驅動
Class.forName(DBDRIVER);
// 2.獲得連接
conn = DriverManager.getConnection(DBURL, DBUSER, DBPASS);
// 3.創建Statement對象
Statement stmt = conn.createStatement();
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
/**
* 關閉資源
* @param statement為履行命令的實例，connection為連接對象
*/
public static void close(Statement statement, Connection connection) {
{
try {
if (statement != null)
statement.close();
if (connection != null) {
connection.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
/**
* 創建1個
數據庫表，注意這里的表要事前存在的
*/
public void CreatTable() {
// 1.獲得連接
Connection connection = SqlDB.getconnection();
// 2.準備sql語句
String sql = "CREATE TABLE student(sid INT PRIMARY KEY,sname VARCHAR(20),age INT)";
PreparedStatement preparedStatement = null;
// 3.取得對象
try {
preparedStatement = connection.prepareStatement(sql);
} catch (SQLException e) {
e.printStackTrace();
}
// 4.交給
數據庫履行SQL
int num = 0;
try {
num = preparedStatement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
System.out.println("有" + num + "條記錄遭到了影響");
SqlDB.close(preparedStatement, connection);
}
/**
* 履行插入操作
* @param 相應的參數
*/
public void InsertData(int id, String name, int age) {
// 1.獲得連接
Connection connection = SqlDB.getconnection();
// 2.準備sql語句
String sql = "INSERT INTO student VALUES(?,?,?)";
PreparedStatement preparedStatement = null;
// 3.取得對象
try {
preparedStatement = connection.prepareStatement(sql);
} catch (SQLException e) {
e.printStackTrace();
}
// 4.設置SQL參數 需要參數是第幾個，并且知道它的類型 下面第1句表示：SQL語句第1個參數是int類型，參數值設置為id，如此類推
try {
preparedStatement.setInt(1, id);
preparedStatement.setString(2, name);
preparedStatement.setInt(3, age);
} catch (SQLException e1) {
e1.printStackTrace();
}
// 5.交給
數據庫履行SQL
int num = 0;
try {
num = preparedStatement.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
System.out.println("有" + num + "條記錄遭到了影響");
SqlDB.close(preparedStatement, connection);
}
/**
* 履行查找操作
* @param id 學生編號
*/
public void SelectDataWithId(int id) {
// 1.獲得連接
Connection connection = SqlDB.getconnection();
// 2.準備sql語句
String sql = "SELECT* FROM student where sid=?";
PreparedStatement preparedStatement = null;
ResultSet res = null;
// 3.取得對象
try {
preparedStatement = connection.prepareStatement(sql);
} catch (SQLException e) {
e.printStackTrace();
}
/*
* 4.設置SQL參數 需要參數是第幾個，并且知道它的類型 下面第1句表示：SQL語句第1個參數是int類型，參數值設置為id，如此類推
*/
try {
preparedStatement.setInt(1, id);
} catch (SQLException e1) {
e1.printStackTrace();
}
// 5.交給
數據庫履行SQL
try {
res = preparedStatement.executeQuery();
while (res.next()) {
// 先獲得數據
int sid = res.getInt("sid");
String sname = res.getString("sname");
int age = res.getInt("age");
// 打印結果
System.out.print("sid: " + sid);
System.out.print(" sname: " + sname);
System.out.println(" age: " + age);
}
} catch (SQLException e1) {
e1.printStackTrace();
}
SqlDB.close(preparedStatement, connection);
}
}
SqlDB sqlDB=new SqlDB();
sqlDB.CreatTable();
sqlDB.InsertData(309, "小紅",12);
sqlDB.InsertData(33, "小灰",34);
sqlDB.InsertData(23, "阿大",145);
sqlDB.SelectDataWithId(33);
在這里，我們使用了PreparedStatement來進行數據庫操作，下面說說它們的區分
Statement 與 PreparedStatement的區分：
1.語法不同
Statement只支持靜態編譯，SQL語句是寫死的。
PreparedStatement支持預編譯，用？號來占位。
2.效力不同
Statement每次都要發送1條SQL語句，不支持緩存，履行效力低。
PreparedStatement支持預編譯，緩存在數據庫，只需發送參數，履行效力快。
3.安全性不同
Statement容易被注入。
注入：狡猾的份子可以編寫特殊的SQL語句來入侵數據庫。
例如：要查詢某個用戶的信息
1般情況：SELECT * FROM user_list where username=xxx and password=xxx;(這里的xxx本應為用戶填寫自己的用戶名和密碼)
注入情況：SELECT * FROM user_list where username='abc' or 1=1 -- password=xxx;
這樣1=1恒等，而且在password前加上了“--”號，后面的內容成了注釋不被履行。也就是說，這樣就可以不用密碼地查詢所有的用戶信息。
PreparedStatement，由于規定了SQL語句中的參數，所以可以避免注入。
結論：建議使用PreparedStatement，由于它更快更安全。
7、JDBC用法小結
DriverManger:驅動管理器類
要操作數據庫，必須先與數據庫創建連接，得到連接對象
public static Connection getConnection(String url, String username,String password){}
Connection:連接接口：
通過DriverManger類的getConnection方法，將取得連接對象，履行sql語句必須借助語句對象(Statement)
Statement createStatement();
Statement:語句接口
通過連接對象的createStatement方法取得語句對象后，語句對象便可履行sql語句，Statement中提供了executeUpdate、executeQuery語句，分別履行不同的sql語句
int executeUpdate(String sql):履行增刪改操作的語句，返回值為操作的總行數
ResultSet executeQuery(String sql)：履行查詢語句，返回值為查詢結果集合
ResultSet：結果集接口
boolean next()：該方法可使結果集游標向下移動，如果仍有記錄返回true，如果已遍歷結束，返回false
getXXX(String columnName):該系列方法用來根據字段名返回字段的值結果集接口里面有大量的getXXX(String columnName)方法，如getString，getInt等
getXXX(int index)：該系列方法用來根據字段在結果集中的索引值返回字段的值，結果集中有大量的getXXX方法，與 上面的類似，用來根據索引值，獲得該字段的值，XXX是該字段的數據類型。
JDBC語句對象：
Statement:如上 stmt = conn.createStatement();
PrepareStatement:稱為預編譯的語句對象，是Statement的子接口 stmt = conn.prepareStatement(String sql),和Statement的不同的地方林炳文Evankaka原創作品。轉載請注明出處http://blog.csdn.net/evankaka
生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈
