Jdbc入門

時間 2019-12-20

標籤 jdbc 入門欄目 Java 简体版

原文原文鏈接

JDBC入門html

l 導jar包：驅動！java

l 加載驅動類：Class.forName(「類名」);mysql

l 給出url、username、password，其中url背下來！sql

l 使用DriverManager類來獲得Connection對象！數據庫

1　什麼是JDBC

　　JDBC（Java DataBase Connectivity）就是Java數據庫鏈接，說白了就是用Java語言來操做數據庫。原來咱們操做數據庫是在控制檯使用SQL語句來操做數據庫，JDBC是用Java語言向數據庫發送SQL語句。數組

2　JDBC原理

早期SUN公司的天才們想編寫一套能夠鏈接天下全部數據庫的API，可是當他們剛剛開始時就發現這是不可完成的任務，由於各個廠商的數據庫服務器差別太大了。後來SUN開始與數據庫廠商們討論，最終得出的結論是，由SUN提供一套訪問數據庫的規範（就是一組接口），並提供鏈接數據庫的協議標準，而後各個數據庫廠商會遵循SUN的規範提供一套訪問本身公司的數據庫服務器的API出現。SUN提供的規範命名爲JDBC，而各個廠商提供的，遵循了JDBC規範的，能夠訪問本身數據庫的API被稱之爲驅動！瀏覽器

JDBC是接口，而JDBC驅動纔是接口的實現，沒有驅動沒法完成數據庫鏈接！每一個數據庫廠商都有本身的驅動，用來鏈接本身公司的數據庫。服務器

固然還有第三方公司專門爲某一數據庫提供驅動，這樣的驅動每每不是開源免費的！dom

3　JDBC核心類（接口）介紹

JDBC中的核心類有：DriverManager、Connection、Statement，和ResultSet！函數

DriverManger（驅動管理器）的做用有兩個：

l 註冊驅動：這可讓JDBC知道要使用的是哪一個驅動；

l 獲取Connection：若是能夠獲取到Connection，那麼說明已經與數據庫鏈接上了。

Connection對象表示鏈接，與數據庫的通信都是經過這個對象展開的：

l Connection最爲重要的一個方法就是用來獲取Statement對象；

Statement是用來向數據庫發送SQL語句的，這樣數據庫就會執行發送過來的SQL語句：

l void executeUpdate(String sql)：執行更新操做（insert、update、delete等）；

l ResultSet executeQuery(String sql)：執行查詢操做，數據庫在執行查詢後會把查詢結果，查詢結果就是ResultSet；

ResultSet對象表示查詢結果集，只有在執行查詢操做後纔會有結果集的產生。結果集是一個二維的表格，有行有列。操做結果集要學習移動ResultSet內部的「行光標」，以及獲取當前行上的每一列上的數據：

l boolean next()：使「行光標」移動到下一行，並返回移動後的行是否存在；

l XXX getXXX(int col)：獲取當前行指定列上的值，參數就是列數，列數從1開始，而不是0。

4　Hello JDBC

下面開始編寫第一個JDBC程序

4.1　mysql數據庫的驅動jar包：mysql-connector-java-5.1.13-bin.jar；

4.2　獲取鏈接

獲取鏈接須要兩步，一是使用DriverManager來註冊驅動，二是使用DriverManager來獲取Connection對象。

註冊驅動

看清楚了，註冊驅動就只有一句話：Class.forName(「com.mysql.jdbc.Driver」)，下面的內容都是對這句代碼的解釋。從此咱們的代碼中，與註冊驅動相關的代碼只有這一句。

DriverManager類的registerDriver()方法的參數是java.sql.Driver，但java.sql.Driver是一個接口，實現類由mysql驅動來提供，mysql驅動中的java.sql.Driver接口的實現類爲com.mysql.jdbc.Driver！那麼註冊驅動的代碼以下：

DriverManager.registerDriver(new com.mysql.jdbc.Driver());

上面代碼雖然能夠註冊驅動，可是出現硬編碼（代碼依賴mysql驅動jar包），若是未來想鏈接Oracle數據庫，那麼必需要修改代碼的。而且其實這種註冊驅動的方式是註冊了兩次驅動！

JDBC中規定，驅動類在被加載時，須要本身「主動」把本身註冊到DriverManger中，下面咱們來看看com.mysql.jdbc.Driver類的源代碼：

com.mysql.jdbc.Driver.java

public class Driver extends NonRegisteringDriver implements java.sql.Driver {

static {

try {

java.sql.DriverManager.registerDriver(new Driver());

} catch (SQLException E) {

throw new RuntimeException("Can't register driver!");

}

……

}

com.mysql.jdbc.Driver類中的static塊會建立本類對象，並註冊到DriverManager中。這說明只要去加載com.mysql.jdbc.Driver類，那麼就會執行這個static塊，從而也就會把com.mysql.jdbc.Driver註冊到DriverManager中，因此能夠把註冊驅動類的代碼修改成加載驅動類。

Class.forName(「com.mysql.jdbc.Driver」);

獲取鏈接

獲取鏈接的也只有一句代碼：DriverManager.getConnection(url,username,password)，其中username和password是登陸數據庫的用戶名和密碼，若是我沒說錯的話，你的mysql數據庫的用戶名和密碼分別是：root、123。

url查對複雜一點，它是用來找到要鏈接數據庫「網址」，就比如你要瀏覽器中查找百度時，也須要提供一個url。下面是mysql的url：

jdbc:mysql://localhost:3306/mydb1

JDBC規定url的格式由三部分組成，每一個部分中間使用逗號分隔。

l 第一部分是jdbc，這是固定的；

l 第二部分是數據庫名稱，那麼鏈接mysql數據庫，第二部分固然是mysql了；

l 第三部分是由數據庫廠商規定的，咱們須要瞭解每一個數據庫廠商的要求，mysql的第三部分分別由數據庫服務器的IP地址（localhost）、端口號（3306），以及DATABASE名稱(mydb1)組成。

下面是獲取鏈接的語句：

Connection con = DriverManager.getConnection(「jdbc:mysql://localhost:3306/mydb1」,」root」,」123」);

還能夠在url中提供參數：

jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=UTF8

useUnicode參數指定這個鏈接數據庫的過程當中，使用的字節集是Unicode字節集；

characherEncoding參數指定穿上鍊接數據庫的過程當中，使用的字節集編碼爲UTF-8編碼。請注意，mysql中指定UTF-8編碼是給出的是UTF8，而不是UTF-8。要當心了！

4.3　獲取Statement

在獲得Connectoin以後，說明已經與數據庫鏈接上了，下面是經過Connection獲取Statement對象的代碼：

Statement stmt = con.createStatement();

Statement是用來向數據庫發送要執行的SQL語句的！

4.4　發送SQL增、刪、改語句

String sql = 「insert into user value(’zhangSan’, ’123’)」;

int m = stmt.executeUpdate(sql);

其中int類型的返回值表示執行這條SQL語句所影響的行數，咱們知道，對insert來講，最後只能影響一行，而update和delete可能會影響0~n行。

若是SQL語句執行失敗，那麼executeUpdate()會拋出一個SQLException。

4.5　發送SQL查詢語句

String sql = 「select * from user」;

ResultSet rs = stmt.executeQuery(sql);

請註冊，執行查詢使用的不是executeUpdate()方法，而是executeQuery()方法。executeQuery()方法返回的是ResultSet，ResultSet封裝了查詢結果，咱們稱之爲結果集。

4.6　讀取結果集中的數據

ResultSet就是一張二維的表格，它內部有一個「行光標」，光標默認的位置在「第一行上方」，咱們能夠調用rs對象的next()方法把「行光標」向下移動一行，當第一次調用next()方法時，「行光標」就到了第一行記錄的位置，這時就可使用ResultSet提供的getXXX(int col)方法來獲取指定列的數據了：

rs.next();//光標移動到第一行

rs.getInt(1);//獲取第一行第一列的數據

當你使用rs.getInt(1)方法時，你必須能夠確定第1列的數據類型就是int類型，若是你不能確定，那麼最好使用rs.getObject(1)。在ResultSet類中提供了一系列的getXXX()方法，比較經常使用的方法有：

Object getObject(int col)

String getString(int col)

int getInt(int col)

double getDouble(int col)

4.7　關閉

與IO流同樣，使用後的東西都須要關閉！關閉的順序是先獲得的後關閉，後獲得的先關閉。

rs.close();

stmt.close();

con.close();

4.8　代碼

public static Connection getConnection() throws Exception {

Class.forName("com.mysql.jdbc.Driver");

String url = "jdbc:mysql://localhost:3306/mydb1";

return DriverManager.getConnection(url, "root", "123");

}

@Test

public void insert() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "insert into user values('zhangSan', '123')";

stmt.executeUpdate(sql);

System.out.println("插入成功！");

}

@Test

public void update() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "update user set password='456' where username='zhangSan'";

stmt.executeUpdate(sql);

System.out.println("修改爲功！");

}

@Test

public void delete() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "delete from user where username='zhangSan'";

stmt.executeUpdate(sql);

System.out.println("刪除成功！");

}

@Test

public void query() throws Exception {

Connection con = getConnection();

Statement stmt = con.createStatement();

String sql = "select * from user";

ResultSet rs = stmt.executeQuery(sql);

while(rs.next()) {

String username = rs.getString(1);

String password = rs.getString(2);

System.out.println(username + ", " + password);

}

4.9　規範化代碼

所謂規範化代碼就是不管是否出現異常，都要關閉ResultSet、Statement，以及Connection，若是你還記得IO流的規範化代碼，那麼下面的代碼你就明白什麼意思了。

@Test

public void query() {

Connection con = null;

Statement stmt = null;

ResultSet rs = null;

[c1] try {

con = getConnection();[c2]

stmt = con.createStatement();

String sql = "select * from user";

rs = stmt.executeQuery(sql);

while(rs.next()) {

String username = rs.getString(1);

String password = rs.getString(2);

System.out.println(username + ", " + password);

}

} catch(Exception e) {

throw new RuntimeException(e);

} finally {

try {

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(con != null) con.close();

[c3] } catch(SQLException e) {}

}

JDBC對象介紹

1　JDBC中的主要類（接口）

在JDBC中經常使用的類有：

l DriverManager；

l Connection；

l Statement；

l ResultSet。

2　DriverManager

其實咱們從此只須要會用DriverManager的getConnection()方法便可：

Class.forName(「com.mysql.jdbc.Driver」);//註冊驅動
String url = 「jdbc:mysql://localhost:3306/mydb1」;
String username = 「root」;
String password = 「123」;
Connection con = DriverManager.getConnection(url, username, password);

注意，上面代碼可能出現的兩種異常：

ClassNotFoundException：這個異常是在第1句上出現的，出現這個異常有兩個可能：

l 你沒有給出mysql的jar包；

l 你把類名稱打錯了，查看類名是否是com.mysql.jdbc.Driver。

SQLException：這個異常出如今第5句，出現這個異常就是三個參數的問題，每每username和password通常不是出錯，因此須要認真查看url是否打錯。

對於DriverManager.registerDriver()方法瞭解便可，由於咱們從此註冊驅動只會Class.forName()，而不會使用這個方法。

3　Connection

Connection最爲重要的方法就是獲取Statement：

l Statement stmt = con.createStatement();

後面在學習ResultSet方法時，還要學習一下下面的方法：

l Statement stmt = con.createStatement(int,int[c4] );

4　Statement

Statement最爲重要的方法是：

l int executeUpdate[c5] (String sql)：執行更新操做，即執行insert、update、delete語句，其實這個方法也能夠執行create table、alter table，以及drop table等語句，但咱們不多會使用JDBC來執行這些語句；

l ResultSet executeQuery[c6] (String sql)：執行查詢操做，執行查詢操做會返回ResultSet，即結果集。

　　boolean execute[c7] ()

Statement還有一個boolean execute()方法，這個方法能夠用來執行增、刪、改、查全部SQL語句。該方法返回的是boolean類型，表示SQL語句是否有結果集！。

若是使用execute()方法執行的是更新語句，那麼還要調用int getUpdateCount()來獲取insert、update、delete語句所影響的行數。

若是使用execute()方法執行的是查詢語句，那麼還要調用ResultSet getResultSet()來獲取select語句的查詢結果。

5　ResultSet之滾動結果集（瞭解）

下一行：默認只能使用它，其餘的方法存在，但不能使用！默認的結果集不可滾動！

上一行

下N行

上N行

到N行！

ResultSet表示結果集，它是一個二維的表格！ResultSet內部維護一個行光標（遊標），ResultSet提供了一系列的方法來移動遊標：

l void beforeFirst()：把光標放到第一行的前面，這也是光標默認的位置；

l void afterLast()：把光標放到最後一行的後面；

l boolean first()：把光標放到第一行的位置上，返回值表示調控光標是否成功；

l boolean last()：把光標放到最後一行的位置上；

l boolean isBeforeFirst()：當前光標位置是否在第一行前面；

l boolean isAfterLast()：當前光標位置是否在最後一行的後面；

l boolean isFirst()：當前光標位置是否在第一行上；

l boolean isLast()：當前光標位置是否在最後一行上；

l boolean previous()：把光標向上挪一行；

l boolean next()：把光標向下挪一行；

l boolean relative(int row)：相對位移，當row爲正數時，表示向下移動row行，爲負數時表示向上移動row行；

l boolean absolute(int row)：絕對位移，把光標移動到指定的行上；

l int getRow()：返回當前光標全部行。

獲取結果集元數據！

l 獲得元數據：rs.getMetaData()，返回值爲ResultSetMetaData；

l 獲取結果集列數：int getColumnCount()

l 獲取指定列的列名：String getColumnName(int colIndex)

結果集特性：當使用Connection的createStatement時，已經肯定了Statement生成的結果集是什麼特性。

l 是否可滾動

l 是否敏感

l 是否可更新

con.createSttement()：生成的結果集：不滾動、不敏感、不可更新！

con.createStatement(int,int)：

第一個參數：

l ResultSet.TYPE_FORWARD_ONLY：不滾動結果集；

l ResultSet.TYPE_SCROLL_INSENSITIVE：滾動結果集，但結果集數據不會再跟隨數據庫而變化；

l ResultSet.TYPE_SCROLL_SENSITIVE[c8] ：滾動結果集，但結果集數據不會再跟隨數據庫而變化；

第二個參數：

l CONCUR_READ_ONLY：結果集是隻讀的，不能經過修改結果集而反向影響數據庫；

l CONCUR_UPDATABLE：結果集是可更新的，對結果集的更新能夠反向影響數據庫。

上面方法分爲兩類，一類用來判斷遊標位置的，另外一類是用來移動遊標的。若是結果集是不可滾動的，那麼只能使用next()方法來移動遊標，而beforeFirst()、afterLast()、first()、last()、previous()、relative()方法都不能使用！！！

結果集是否支持滾動，要從Connection類的createStatement()方法提及。也就是說建立的Statement決定了使用Statement建立的ResultSet是否支持滾動。

Statement createStatement(int resultSetType, int resultSetConcurrency)[c9]

resultSetType的可選值：

l ResultSet.TYPE_FORWARD_ONLY：不滾動結果集；

l ResultSet.TYPE_SCROLL_INSENSITIVE：滾動結果集，但結果集數據不會再跟隨數據庫而變化；

l ResultSet.TYPE_SCROLL_SENSITIVE[c10] ：滾動結果集，但結果集數據不會再跟隨數據庫而變化；

能夠看出，若是想使用滾動的結果集，咱們應該選擇TYPE_SCROLL_INSENSITIVE！其實不多有數據庫驅動會支持TYPE_SCROLL_SENSITIVE的特性！一般咱們也不須要查詢到的結果集再受到數據庫變化的影響。

resultSetConcurrency的可選值：

l CONCUR_READ_ONLY：結果集是隻讀的，不能經過修改結果集而反向影響數據庫；

l CONCUR_UPDATABLE：結果集是可更新的，對結果集的更新能夠反向影響數據庫。

一般可更新結果集這一「高級特性」咱們也是不須要的！

獲取滾動結果集的代碼以下：

Connection con = …

Statement stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, CONCUR_READ_ONLY);

String sql = …//查詢語句

ResultSet rs = stmt.executeQuery(sql);//這個結果集是可滾動的

6　ResultSet之獲取列數據

能夠經過next()方法使ResultSet的遊標向下移動，當遊標移動到你須要的行時，就須要來獲取該行的數據了，ResultSet提供了一系列的獲取列數據的方法：

l String getString(int columnIndex)：獲取指定列的String類型數據；

l int getInt(int columnIndex)：獲取指定列的int類型數據；

l double getDouble(int columnIndex)：獲取指定列的double類型數據；

l boolean getBoolean(int columnIndex)：獲取指定列的boolean類型數據；

l Object getObject(int columnIndex)：獲取指定列的Object類型的數據。

上面方法中，參數columnIndex表示列的索引，列索引從1開始，而不是0，這第一點與數組不一樣。若是你清楚當前列的數據類型，那麼可使用getInt()之類的方法來獲取，若是你不清楚列的類型，那麼你應該使用getObject()方法來獲取。

ResultSet還提供了一套經過列名稱來獲取列數據的方法[c11] ：

l String getString(String columnName)：獲取名稱爲columnName的列的String數據；

l int getInt(String columnName)：獲取名稱爲columnName的列的int數據；

l double getDouble(String columnName)：獲取名稱爲columnName的列的double數據；

l boolean getBoolean(String columnName)：獲取名稱爲columnName的列的boolean數據；

l Object getObject(String columnName)：獲取名稱爲columnName的列的Object數據；

PreparedStatement

l 它是Statement接口的子接口；

l 強大之處：

防SQL攻擊；
提升代碼的可讀性、可維護性；
提升效率！

l 學習PreparedStatement的用法：

如何獲得PreparedStatement對象：

¨ 給出SQL模板！

¨ 調用Connection的PreparedStatement prepareStatement(String sql模板)；

¨ 調用pstmt的setXxx()系列方法sql模板中的?賦值！

¨ 調用pstmt的executeUpdate()或executeQuery()，但它的方法都沒有參數。

l 預處理的原理

服務器的工做：

¨ 校驗sql語句的語法！

¨ 編譯：一個與函數類似的東西！

¨ 執行：調用函數

PreparedStatement：

¨ 前提：鏈接的數據庫必須支持預處理！幾乎沒有不支持的！

¨ 每一個pstmt都與一個sql模板綁定在一塊兒，先把sql模板給數據庫，數據庫先進行校驗，再進行編譯。執行時只是把參數傳遞過去而已！

¨ 若二次執行時，就不用再次校驗語法，也不用再次編譯！直接執行！

1　什麼是SQL攻擊

在須要用戶輸入的地方，用戶輸入的是SQL語句的片斷，最終用戶輸入的SQL片斷與咱們DAO中寫的SQL語句合成一個完整的SQL語句！例如用戶在登陸時輸入的用戶名和密碼都是爲SQL語句的片斷！

2　演示SQL攻擊

首先咱們須要建立一張用戶表，用來存儲用戶的信息。

CREATE TABLE user(

uid CHAR(32) PRIMARY KEY,

username VARCHAR(30) UNIQUE KEY NOT NULL,

PASSWORD VARCHAR(30)

);

INSERT INTO user VALUES('U_1001', 'zs', 'zs');

SELECT * FROM user;

如今用戶表中只有一行記錄，就是zs。

下面咱們寫一個login()方法！

public void login(String username, String password) {

Connection con = null;

Statement stmt = null;

ResultSet rs = null;

try {

con = JdbcUtils.getConnection();

stmt = con.createStatement();

String sql = "SELECT * FROM user WHERE " +

"username='" + username +

"' and password='" + password + "'";

rs = stmt.executeQuery(sql);

if(rs.next()) {

System.out.println("歡迎" + rs.getString("username"));

} else {

System.out.println("用戶名或密碼錯誤！");

}

} catch (Exception e) {

throw new RuntimeException(e);

} finally {

JdbcUtils.close(con, stmt, rs);

}

下面是調用這個方法的代碼：

這行當前會使咱們登陸成功！由於是輸入的用戶名和密碼是SQL語句片斷，最終與咱們的login()方法中的SQL語句組合在一塊兒！咱們來看看組合在一塊兒的SQL語句：

SELECT * FROM tab_user WHERE username='a' or 'a'='a' and password='a' or 'a'='a'

3　防止SQL攻擊

l 過濾用戶輸入的數據中是否包含非法字符；

l 分步交驗！先使用用戶名來查詢用戶，若是查找到了，再比較密碼；

l 使用PreparedStatement。

4　PreparedStatement是什麼？

PreparedStatement叫預編譯聲明！

PreparedStatement是Statement的子接口，你可使用PreparedStatement來替換Statement。

PreparedStatement的好處：

l 防止SQL攻擊；[c12]

l 提升代碼的可讀性，以可維護性；

l 提升效率[c13] 。

5　PreparedStatement的使用

l 使用Connection的prepareStatement(String sql)：即建立它時就讓它與一條SQL模板綁定；

l 調用PreparedStatement的setXXX()系列方法爲問號設置值

l 調用executeUpdate()或executeQuery()方法，但要注意，調用沒有參數的方法；

String sql = 「select * from tab_student where s_number=?」;

PreparedStatement pstmt = con.prepareStatement(sql);

pstmt.setString(1, 「S_1001」);

ResultSet rs = pstmt.executeQuery();

rs.close();

pstmt.clearParameters();[崔14]

pstmt.setString(1, 「S_1002」);

rs = pstmt.executeQuery();

在使用Connection建立PreparedStatement對象時須要給出一個SQL模板，所謂SQL模板就是有「?」的SQL語句，其中「?」就是參數。

在獲得PreparedStatement對象後，調用它的setXXX()方法爲「?」賦值，這樣就能夠獲得把模板變成一條完整的SQL語句，而後再調用PreparedStatement對象的executeQuery()方法獲取ResultSet對象。

注意PreparedStatement對象獨有的executeQuery()方法是沒有參數的，而Statement的executeQuery()是須要參數（SQL語句）的。由於在建立PreparedStatement對象時已經讓它與一條SQL模板綁定在一塊兒了，因此在調用它的executeQuery()和executeUpdate()方法時就再也不須要參數了。

PreparedStatement最大的好處就是在於重複使用同一模板，給予其不一樣的參數來重複的使用它。這纔是真正提升效率的緣由。

因此，建議你們在從此的開發中，不管什麼狀況，都去須要PreparedStatement，而不是使用Statement。

JdbcUtils工具類

1　JdbcUtils的做用

你也看到了，鏈接數據庫的四大參數是：驅動類、url、用戶名，以及密碼。這些參數都與特定數據庫關聯，若是未來想更改數據庫，那麼就要去修改這四大參數，那麼爲了避免去修改代碼，咱們寫一個JdbcUtils類，讓它從配置文件中讀取配置參數，而後建立鏈接對象。

2　JdbcUtils代碼

JdbcUtils.java

public class JdbcUtils {

private static final String dbconfig = "dbconfig.properties"[崔15] ;

private static Properties prop = new Properties()[崔16] ;

static {

try {

InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream(dbconfig);

prop.load(in);

Class.forName(prop.getProperty("driverClassName"));

} catch(IOException e) {

throw new RuntimeException(e);

}

}[崔17]

public static Connection getConnection[崔18] () {

try {

return DriverManager.getConnection(prop.getProperty("url"),

prop.getProperty("username"), prop.getProperty("password"));

} catch (Exception e) {

throw new RuntimeException(e);

}

dbconfig.properties

driverClassName=com.mysql.jdbc.Driver

url=jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=UTF8

username=root

password=123

UserDao

修改項目：

把UserDao修改成接口，而後把原來的UserDao修改類名爲UserDaoImpl
修改UserService中對UserDao的實例化：private UserDao userDao = DaoFactory.getUserDao()
建立DaoFactory，提供getUserDao()

1　DAO模式

DAO（Data Access Object）模式就是寫一個類，把訪問數據庫的代碼封裝起來。DAO在數據庫與業務邏輯（Service）之間。

l 實體域，即操做的對象，例如咱們操做的表是user表，那麼就須要先寫一個User類；

l DAO模式須要先提供一個DAO接口；

l 而後再提供一個DAO接口的實現類；

l 再編寫一個DAO工廠，Service經過工廠來獲取DAO實現。

2　代碼

User.java

public class User {

private String uid;

private String username;

private String password;

…

}

UserDao.java

public interface UserDao {

public void add(User user);

public void mod(User user);

public void del(String uid);

public User load(String uid);

public List<User> findAll();

}

UserDaoImpl.java

public class UserDaoImpl implements UserDao {

public void add(User user) {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = JdbcUtils.getConnection();

String sql = "insert into user value(?,?,?)";

pstmt = con.prepareStatement(sql);

pstmt.setString(1, user.getUid());

pstmt.setString(2, user.getUsername());

pstmt.setString(3, user.getPassword());

pstmt.executeUpdate();

} catch(Exception e) {

throw new RuntimeException(e);

} finally {

try {

if(pstmt != null) pstmt.close();

if(con != null) con.close();

} catch(SQLException e) {}

}

public void mod(User user) {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = JdbcUtils.getConnection();

String sql = "update user set username=?, password=? where uid=?";

pstmt = con.prepareStatement(sql);

pstmt.setString(1, user.getUsername());

pstmt.setString(2, user.getPassword());

pstmt.setString(3, user.getUid());

pstmt.executeUpdate();

} catch(Exception e) {

throw new RuntimeException(e);

} finally {

try {

if(pstmt != null) pstmt.close();

if(con != null) con.close();

} catch(SQLException e) {}

}

public void del(String uid) {

Connection con = null;

PreparedStatement pstmt = null;

try {

con = JdbcUtils.getConnection();

String sql = "delete from user where uid=?";

pstmt = con.prepareStatement(sql);

pstmt.setString(1, uid);

pstmt.executeUpdate();

} catch(Exception e) {

throw new RuntimeException(e);

} finally {

try {

if(pstmt != null) pstmt.close();

if(con != null) con.close();

} catch(SQLException e) {}

}

public User load(String uid) {

Connection con = null;

PreparedStatement pstmt = null;

ResultSet rs = null;

try {

con = JdbcUtils.getConnection();

String sql = "select * from user where uid=?";

pstmt = con.prepareStatement(sql);

pstmt.setString(1, uid);

rs = pstmt.executeQuery();

if(rs.next()) {

return new User(rs.getString(1), rs.getString(2), rs.getString(3));

}

return null;

} catch(Exception e) {

throw new RuntimeException(e);

} finally {

try {

if(pstmt != null) pstmt.close();

if(con != null) con.close();

} catch(SQLException e) {}

}

public List<User> findAll() {

Connection con = null;

PreparedStatement pstmt = null;

ResultSet rs = null;

try {

con = JdbcUtils.getConnection();

String sql = "select * from user";

pstmt = con.prepareStatement(sql);

rs = pstmt.executeQuery();

List<User> userList = new ArrayList<User>();

while(rs.next()) {

userList.add(new User(rs.getString(1), rs.getString(2), rs.getString(3)));

}

return userList;

} catch(Exception e) {

throw new RuntimeException(e);

} finally {

try {

if(pstmt != null) pstmt.close();

if(con != null) con.close();

} catch(SQLException e) {}

}

UserDaoFactory.java

public class UserDaoFactory {

private static UserDao userDao;

static {

try {

InputStream in = Thread.currentThread().getContextClassLoader()

.getResourceAsStream("dao.properties");

Properties prop = new Properties();

prop.load(in);

String className = prop.getProperty("cn.itcast.jdbc.UserDao");

Class clazz = Class.forName(className);

userDao = (UserDao) clazz.newInstance();

} catch (Exception e) {

throw new RuntimeException(e);

}

public static UserDao getUserDao() {

return userDao;

}

dao.properties

cn.itcast.jdbc.UserDao=cn.itcast.jdbc.UserDaoImpl

時間類型

數據庫類型與java中類型的對應關係：

DATE à java.sql.Date

TIME à java.sql.Time

TIMESTAMP à java.sql.Timestamp

l 領域對象（domain）中的全部屬性不能出現java.sql包下的東西！即不能使用java.sql.Date；

l ResultSet#getDate()返回的是java.sql.Date()

l PreparedStatement#setDate(int, Date)，其中第二個參數也是java.sql.Date

時間類型的轉換：

l java.util.Date à java.sql.Date、Time、Timestamp

把util的Date轉換成毫秒值
使用毫秒值建立sql的Date、Time、Timestamp

l java.sql.Date、Time、Timestamp à java.util.Date

這一步不須要處理了：由於java.sql.Date是java.util.Date；

java.util.Date date = new java.util.Date();

long l = date.getTime();

java.sql.Date sqlDate = new java.sql.Date(l);

1　Java中的時間類型

java.sql包下給出三個與數據庫相關的日期時間類型，分別是：

l Date：表示日期，只有年月日，沒有時分秒。會丟失時間；

l Time：表示時間，只有時分秒，沒有年月日。會丟失日期；

l Timestamp：表示時間戳，有年月日時分秒，以及毫秒。

這三個類都是java.util.Date的子類。

2　時間類型相互轉換

把數據庫的三種時間類型賦給java.util.Date，基本不用轉換，由於這是把子類對象給父類的引用，不須要轉換。

java.sql.Date date = …

java.util.Date d = date;

java.sql.Time time = …

java.util.Date d = time;

java.sql.Timestamp timestamp = …

java.util.Date d = timestamp;

當須要把java.util.Date轉換成數據庫的三種時間類型時，這就不能直接賦值了，這須要使用數據庫三種時間類型的構造器。java.sql包下的Date、Time、TimeStamp三個類的構造器都須要一個long類型的參數，表示毫秒值。建立這三個類型的對象，只須要有毫秒值便可。咱們知道java.util.Date有getTime()方法能夠獲取毫秒值，那麼這個轉換也就不是什麼問題了。

java.utl.Date d = new java.util.Date();

java.sql.Date date = new java.sql.Date(d.getTime());//會丟失時分秒

Time time = new Time(d.getTime());//會丟失年月日

Timestamp timestamp = new Timestamp(d.getTime());

3　代碼

咱們來建立一個dt表：

CREATE TABLE dt(

d DATE,

t TIME,

ts TIMESTAMP

)

下面是向dt表中插入數據的代碼：

@Test

public void fun1() throws SQLException {

Connection con = JdbcUtils.getConnection();

String sql = "insert into dt value(?,?,?)";

PreparedStatement pstmt = con.prepareStatement(sql);

java.util.Date d = new java.util.Date();

pstmt.setDate(1, new java.sql.Date(d.getTime()));

pstmt.setTime(2, new Time(d.getTime()));

pstmt.setTimestamp(3, new Timestamp(d.getTime()));

pstmt.executeUpdate();

}

下面是從dt表中查詢數據的代碼：

@Test

public void fun2() throws SQLException {

Connection con = JdbcUtils.getConnection();

String sql = "select * from dt";

PreparedStatement pstmt = con.prepareStatement(sql);

ResultSet rs = pstmt.executeQuery();

rs.next();

java.util.Date d1 = rs.getDate(1);

java.util.Date d2 = rs.getTime(2);

java.util.Date d3 = rs.getTimestamp(3);

System.out.println(d1);

System.out.println(d2);

System.out.println(d3);

}

大數據

目標：把mp3保存到數據庫中！

在my.ini中添加以下配置！

max_allowed_packet=10485760

1　什麼是大數據

所謂大數據，就是大的字節數據，或大的字符數據。標準SQL中提供了以下類型來保存大數據類型：

類型	長度
tinyblob	2^8--1B（256B）
blob	2¹⁶-1B（64K）
mediumblob	2²⁴-1B（16M）
longblob	2³²-1B（4G）
tinyclob	2^8--1B（256B）
clob	2¹⁶-1B（64K）
mediumclob	2²⁴-1B（16M）
longclob	2³²-1B（4G）

可是，在mysql中沒有提供tinyclob、clob、mediumclob、longclob四種類型，而是使用以下四種類型來處理文本大數據：

類型	長度
tinytext	2^8--1B（256B）
text	2¹⁶-1B（64K）
mediumtext	2²⁴-1B（16M）
longtext	2³²-1B（4G）

首先咱們須要建立一張表，表中要有一個mediumblob（16M）類型的字段。

CREATE TABLE tab_bin(

id INT PRIMARY KEY AUTO_INCREMENT,

filename VARCHAR(100),

data MEDIUMBLOB

);

　　向數據庫插入二進制數據須要使用PreparedStatement爲原setBinaryStream(int, InputSteam)方法來完成。

con = JdbcUtils.getConnection();

String sql = "insert into tab_bin(filename,data) values(?, ?)";

pstmt = con.prepareStatement(sql);

pstmt.setString(1, "a.jpg");

InputStream in = new FileInputStream("f:\\a.jpg");[崔19]

pstmt.setBinaryStream(2, in);[崔20]

pstmt.executeUpdate();

讀取二進制數據，須要在查詢後使用ResultSet類的getBinaryStream()方法來獲取輸入流對象。也就是說，PreparedStatement有setXXX()，那麼ResultSet就有getXXX()。

con = JdbcUtils.getConnection();

String sql = "select filename,data from tab_bin where id=?";

pstmt = con.prepareStatement(sql);

pstmt.setInt(1, 1);

rs = pstmt.executeQuery();

rs.next();

String filename = rs.getString("filename");

OutputStream out = new FileOutputStream("F:\\" + filename)[崔21] ;

InputStream in = rs.getBinaryStream("data")[崔22] ;

IOUtils.copy(in, out)[崔23] ;

out.close();

　　還有一種方法，就是把要存儲的數據包裝成Blob類型，而後調用PreparedStatement的setBlob()方法來設置數據

con = JdbcUtils.getConnection();

String sql = "insert into tab_bin(filename,data) values(?, ?)";

pstmt = con.prepareStatement(sql);

pstmt.setString(1, "a.jpg");

File file = new File("f:\\a.jpg");

byte[] datas = FileUtils.getBytes(file);//獲取文件中的數據

Blob blob = new SerialBlob(datas);//建立Blob對象

pstmt.setBlob(2, blob);//設置Blob類型的參數

pstmt.executeUpdate();

con = JdbcUtils.getConnection();

String sql = "select filename,data from tab_bin where id=?";

pstmt = con.prepareStatement(sql);

pstmt.setInt(1, 1);

rs = pstmt.executeQuery();

rs.next();

String filename = rs.getString("filename");

File file = new File("F:\\" + filename) ;

Blob blob = rs.getBlob("data");

byte[] datas = blob.getBytes(0, (int)file.length());

FileUtils.writeByteArrayToFile(file, datas);

批處理

1　Statement批處理

批處理就是一批一批的處理，而不是一個一個的處理！

當你有10條SQL語句要執行時，一次向服務器發送一條SQL語句，這麼作效率上不好！處理的方案是使用批處理，即一次向服務器發送多條SQL語句，而後由服務器一次性處理。

批處理只針對更新（增、刪、改）語句，批處理沒有查詢什麼事兒！

能夠屢次調用Statement類的addBatch(String sql)方法，把須要執行的全部SQL語句添加到一個「批」中，而後調用Statement類的executeBatch()方法來執行當前「批」中的語句。

l void addBatch(String sql)：添加一條語句到「批」中；

l int[] executeBatch()：執行「批」中全部語句。返回值表示每條語句所影響的行數據；

l void clearBatch()：清空「批」中的全部語句。

for(int i = 0; i < 10; i++) {

String number = "S_10" + i;

String name = "stu" + i;

int age = 20 + i;

String gender = i % 2 == 0 ? "male" : "female";

String sql = "insert into stu values('" + number + "', '" + name + "', " + age + ", '" + gender + "')";

stmt[c24] .addBatch(sql);

}

stmt.executeBatch[c25] ();

當執行了「批」以後，「批」中的SQL語句就會被清空！也就是說，連續兩次調用executeBatch()至關於調用一次！由於第二次調用時，「批」中已經沒有SQL語句了。

還能夠在執行「批」以前，調用Statement的clearBatch()方法來清空「批」！

2　PreparedStatement批處理

PreparedStatement的批處理有所不一樣，由於每一個PreparedStatement對象都綁定一條SQL模板。因此向PreparedStatement中添加的不是SQL語句，而是給「?」賦值。

con = JdbcUtils.getConnection();

String sql = "insert into stu values(?,?,?,?)";

pstmt = con.prepareStatement(sql);

for(int i = 0; i < 10; i++) {

pstmt.setString(1, "S_10" + i);

pstmt.setString(2, "stu" + i);

pstmt.setInt(3, 20 + i);

pstmt.setString(4, i % 2 == 0 ? "male" : "female");

pstmt.addBatch()[崔26] ;

}

pstmt.executeBatch[崔27] ();

[c1]在try外給出引用的定義

[c2]在try內爲對象實例化

[c3]在finally中進行關閉

[c4]這兩個參數是用來肯定建立的Statement能生成什麼樣的結果集

[c5]create、alter、drop、insert、update、delete

[c6]select

[c7]瞭解！能夠執行executeUpdate()和executeQuery()兩個方法能執行的sql語句

[c8]沒有數據庫驅動會支持它！

[c9]瞭解

[c10]沒有數據庫驅動會支持它！

[c11]獲取一列的數據，有兩種方式，getXxx(int columIndex)，還有一種：getXxx(String columnName)

[c12]不僅它能夠防！

[c13]很重要！

[崔14]再次使用時須要把原來的設置清空。

[崔15]配置文件路徑

[崔16]對應配置文件

[崔17]把配置文件內容加載到prop對象中。由於是放到static塊中完成的加載操做，因此加載操做只會在JdbcUtils類被加載時完成對配置文件的加載。

[崔18]獲取Connection方法，參數都是從prop中獲取。

[崔19]獲得一個輸入流對象

[崔20]爲第二個參數賦值爲流對象

[崔21]使用文件名來建立輸出流對象。

[崔22]讀取輸入流對象

[崔23]把in中的數據寫入到out中。

[c24]內部有個集合，用來裝載sql語句

[c25]執行批，即一次把批中的全部sql語句發送給服務器

[崔26]PreparedStatement的addBatch()方法沒有參數！

[崔27]執行批

1. JDBC入門
2. 【JDBC入門】
3. Java JDBC入門
4. JDBC 入門
5. JDBC(Mysql)入門
6. JDBC-JDBC開發入門
7. JDBC入門小結
8. Java中JDBC入門
9. JDBC入門詳解
10. jdbc基礎入門
更多相關文章...
• Memcached入門教程 - NoSQL教程
• Neo4j數據庫入門教程 - NoSQL教程
• YAML 入門教程
• Java Agent入門實戰（一）-Instrumentation介紹與使用

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。

Jdbc入門

1 什麼是JDBC

2 JDBC原理

3 JDBC核心類（接口）介紹

4 Hello JDBC

JDBC對象介紹

1 JDBC中的主要類（接口）

2 DriverManager

3 Connection

4 Statement

5 ResultSet之滾動結果集（瞭解）

6 ResultSet之獲取列數據

PreparedStatement

1 什麼是SQL攻擊

2 演示SQL攻擊

3 防止SQL攻擊

4 PreparedStatement是什麼？

5 PreparedStatement的使用

JdbcUtils工具類

1 JdbcUtils的做用

2 JdbcUtils代碼

UserDao

1 DAO模式

2 代碼

時間類型

1 Java中的時間類型

2 時間類型相互轉換

3 代碼

大數據

1 什麼是大數據

批處理

1 Statement批處理

2 PreparedStatement批處理

1　什麼是JDBC

2　JDBC原理

3　JDBC核心類（接口）介紹

4　Hello JDBC

1　JDBC中的主要類（接口）

2　DriverManager

3　Connection

4　Statement

5　ResultSet之滾動結果集（瞭解）

6　ResultSet之獲取列數據

1　什麼是SQL攻擊

2　演示SQL攻擊

3　防止SQL攻擊

4　PreparedStatement是什麼？

5　PreparedStatement的使用

1　JdbcUtils的做用

2　JdbcUtils代碼

1　DAO模式

2　代碼

1　Java中的時間類型

2　時間類型相互轉換

3　代碼

1　什麼是大數據

1　Statement批處理

2　PreparedStatement批處理