8、JDBC入门整理
JDBC入門
l? 導jar包:驅動!
l? 加載驅動類:Class.forName(“類名”);
l? 給出url、username、password,
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驅動才是接口的實現,沒有驅動無法完成數據庫連接!每個數據庫廠商都有自己的驅動,用來連接自己公司的數據庫。
當然還有第三方公司專門為某一數據庫提供驅動,這樣的驅動往往不是開源免費的!
?
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 獲取連接
獲取連接需要兩步,一是使用Driver Manager來注冊驅動,二是使用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(createStatement)
在得到Connectoin之后,說明已經與數據庫連接上了,下面是通過Connection創建Statement對象的代碼:
Statement stmt = con.createStatement();
Statement是用來向數據庫發送要執行的SQL語句的!
4.4 發送SQL增、刪、改語句(insert? into只會影響一行,delete和update N行)
String sql = “insert into user values(’zhangSan’, ’123’)”;
int m = stmt.executeUpdate(sql);
其中int類型的返回值表示執行這條SQL語句所影響的行數,我們知道,對insert來說,最后只能影響一行,而update和delete可能會影響0~n行。
如果SQL語句執行失敗,那么executeUpdate()會拋出一個SQLException。
4.5 發送SQL查詢語句【ResultSet結果集】
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 規范化代碼(對于異常以及資源的處理,用try catch finally)
所謂規范化代碼就是無論是否出現異常,都要關閉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(); ? ? ? ? } catch(SQLException e) {} ?????? } ??? } |
?
轉載于:https://www.cnblogs.com/hyqblog/p/6400938.html
總結
以上是生活随笔為你收集整理的8、JDBC入门整理的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 做梦梦到自己戴孝是怎么回事
- 下一篇: android闹钟实现原理