jdbc入门(一)
一、JDBC入門
? ? 1.什么是JDBC
????????JDBC(Java DataBase Connectivity)就是Java數(shù)據(jù)庫(kù)連接,說(shuō)白了就是用Java語(yǔ)言來(lái)操作數(shù)據(jù)庫(kù)。原來(lái)我們操作數(shù)據(jù)庫(kù)是在控制臺(tái)使用SQL語(yǔ)句來(lái)操作數(shù)據(jù)庫(kù),JDBC是用Java語(yǔ)言向數(shù)據(jù)庫(kù)發(fā)送SQL語(yǔ)句。
? ? 2.JDBC原理
????????早期SUN公司的天才們想編寫(xiě)一套可以連接天下所有數(shù)據(jù)庫(kù)的API,但是當(dāng)他們剛剛開(kāi)始時(shí)就發(fā)現(xiàn)這是不可完成的任務(wù),因?yàn)楦鱾€(gè)廠商的數(shù)據(jù)庫(kù)服務(wù)器差異太大了。后來(lái)SUN開(kāi)始與數(shù)據(jù)庫(kù)廠商們討論,最終得出的結(jié)論是,由SUN提供一套訪問(wèn)數(shù)據(jù)庫(kù)的規(guī)范(就是一組接口),并提供連接數(shù)據(jù)庫(kù)的協(xié)議標(biāo)準(zhǔn),然后各個(gè)數(shù)據(jù)庫(kù)廠商會(huì)遵循SUN的規(guī)范提供一套訪問(wèn)自己公司的數(shù)據(jù)庫(kù)服務(wù)器的API出現(xiàn)。SUN提供的規(guī)范命名為JDBC,而各個(gè)廠商提供的,遵循了JDBC規(guī)范的,可以訪問(wèn)自己數(shù)據(jù)庫(kù)的API被稱之為驅(qū)動(dòng)!
?
????????
?
????????JDBC是接口,而JDBC驅(qū)動(dòng)才是接口的實(shí)現(xiàn),沒(méi)有驅(qū)動(dòng)無(wú)法完成數(shù)據(jù)庫(kù)連接!每個(gè)數(shù)據(jù)庫(kù)廠商都有自己的驅(qū)動(dòng),用來(lái)連接自己公司的數(shù)據(jù)庫(kù)。
? ? ? ? 當(dāng)然還有第三方公司專門為某一數(shù)據(jù)庫(kù)提供驅(qū)動(dòng),這樣的驅(qū)動(dòng)往往不是開(kāi)源免費(fèi)的!
? ? 3.JDBC核心類(接口)介紹
????????JDBC中的核心類有:DriverManager、Connection、Statement,和ResultSet!
????????DriverManger(驅(qū)動(dòng)管理器)的作用有兩個(gè):
????????????????注冊(cè)驅(qū)動(dòng):這可以讓JDBC知道要使用的是哪個(gè)驅(qū)動(dòng);
????????????????獲取Connection:如果可以獲取到Connection,那么說(shuō)明已經(jīng)與數(shù)據(jù)庫(kù)連接上了。
?
????????Connection對(duì)象表示連接,與數(shù)據(jù)庫(kù)的通訊都是通過(guò)這個(gè)對(duì)象展開(kāi)的:
????????????????Connection最為重要的一個(gè)方法就是用來(lái)獲取Statement對(duì)象;
?
????????Statement是用來(lái)向數(shù)據(jù)庫(kù)發(fā)送SQL語(yǔ)句的,這樣數(shù)據(jù)庫(kù)就會(huì)執(zhí)行發(fā)送過(guò)來(lái)的SQL語(yǔ)句:
????????????????void executeUpdate(String sql):執(zhí)行更新操作(insert、update、delete等);
? ? ? ? ? ? ResultSet executeQuery(String sql):執(zhí)行查詢操作,數(shù)據(jù)庫(kù)在執(zhí)行查詢后會(huì)把查詢結(jié)果返回,查詢結(jié)果就是ResultSet;
?
????????ResultSet對(duì)象表示查詢結(jié)果集,只有在執(zhí)行查詢操作后才會(huì)有結(jié)果集的產(chǎn)生。結(jié)果集是一個(gè)二維的表格,有行有列。操作結(jié)果集要學(xué)習(xí)移動(dòng)ResultSet內(nèi)部的“行光標(biāo)”,以及獲取當(dāng)前行上的每一列上的數(shù)據(jù):
?
????????????????boolean next():使“行光標(biāo)”移動(dòng)到下一行,并返回移動(dòng)后的行是否存在;
????????????????XXX getXXX(int col):獲取當(dāng)前行指定列上的值,參數(shù)就是列數(shù),列數(shù)從1開(kāi)始,而不是0。
? ? 4.編寫(xiě)第一個(gè)JDBC程序
? ? (1)mysql數(shù)據(jù)庫(kù)的驅(qū)動(dòng)jar包:mysql-connector-java-5.1.13-bin.jar;
? ? (2)獲取連接
????????獲取連接需要兩步,一是使用DriverManager來(lái)注冊(cè)驅(qū)動(dòng),二是使用DriverManager來(lái)獲取Connection對(duì)象。
????????Class.forName(“com.mysql.jdbc.Driver”):注冊(cè)驅(qū)動(dòng)
????????DriverManager.getConnection(url,username,password):獲取Connection對(duì)象
????????? ? 不同數(shù)據(jù)庫(kù)的url格式不同,下面是mysql的url
????????????????????jdbc:mysql://localhost:3306/mydb1
JDBC規(guī)定url的格式由三部分組成,每個(gè)部分中間使用逗號(hào)分隔。
????????第一部分是jdbc,這是固定的;
????????第二部分是數(shù)據(jù)庫(kù)名稱,那么連接mysql數(shù)據(jù)庫(kù),第二部分當(dāng)然是mysql了;
????????第三部分是由數(shù)據(jù)庫(kù)廠商規(guī)定的,我們需要了解每個(gè)數(shù)據(jù)庫(kù)廠商的要求,mysql的第三部分分別由數(shù)據(jù)庫(kù)服務(wù)器的IP地址(localhost)、端口號(hào)(3306),以及DATABASE名稱(mydb1)組成。
還可以在url中提供參數(shù):
????????jdbc:mysql://localhost:3306/mydb1?useUnicode=true&characterEncoding=UTF8
????????useUnicode參數(shù)指定這個(gè)連接數(shù)據(jù)庫(kù)的過(guò)程中,使用的字節(jié)集是Unicode字節(jié)集;
????????characherEncoding參數(shù)指定穿上連接數(shù)據(jù)庫(kù)的過(guò)程中,使用的字節(jié)集編碼為UTF-8編碼。請(qǐng)注意,mysql中指定UTF-8編碼是給出的是UTF8,而不是UTF-8。要小心了!
? ? (3)獲取Statement
????????在得到Connectoin之后,說(shuō)明已經(jīng)與數(shù)據(jù)庫(kù)連接上了,下面是通過(guò)Connection獲取Statement對(duì)象的代碼:
????????????Statement stmt = con.createStatement();
????????????Statement是用來(lái)向數(shù)據(jù)庫(kù)發(fā)送要執(zhí)行的SQL語(yǔ)句的!
? ? (4)發(fā)送SQL增刪改語(yǔ)句
????????String sql = “insert into user value(’zhangSan’, ’123’)”;
????????int m = stmt.executeUpdate(sql);
????????其中int類型的返回值表示執(zhí)行這條SQL語(yǔ)句所影響的行數(shù),我們知道,對(duì)insert來(lái)說(shuō),最后只能影響一行,而update和delete可能會(huì)影響0~n行。
????????如果SQL語(yǔ)句執(zhí)行失敗,那么executeUpdate()會(huì)拋出一個(gè)SQLException。
? ? (5)發(fā)送SQL查詢語(yǔ)句
????????String sql = “select * from user”;
????????ResultSet rs = stmt.executeQuery(sql);
????????請(qǐng)注冊(cè),執(zhí)行查詢使用的不是executeUpdate()方法,而是executeQuery()方法。executeQuery()方法返回的是ResultSet,ResultSet封裝了查詢結(jié)果,我們稱之為結(jié)果集。
? ? (6)讀取結(jié)果集中的數(shù)據(jù)
????????ResultSet就是一張二維的表格,它內(nèi)部有一個(gè)“行光標(biāo)”,光標(biāo)默認(rèn)的位置在“第一行上方”,我們可以調(diào)用rs對(duì)象的next()方法把“行光標(biāo)”向下移動(dòng)一行,當(dāng)?shù)谝淮握{(diào)用next()方法時(shí),“行光標(biāo)”就到了第一行記錄的位置,這時(shí)就可以使用ResultSet提供的getXXX(int col)方法來(lái)獲取指定列的數(shù)據(jù)了:
???????????????光標(biāo)移動(dòng)到第一行:rs.next();
????????????????獲取第一行第一列的數(shù)據(jù):rs.getInt(1);
????????當(dāng)你使用rs.getInt(1)方法時(shí),你必須可以肯定第1列的數(shù)據(jù)類型就是int類型,如果你不能肯定,那么最好使用rs.getObject(1)。在ResultSet類中提供了一系列的getXXX()方法,比較常用的方法有:
????????????????Object getObject(int col)
????????????????String getString(int col)
????????????????int getInt(int col)
????????????????double getDouble(int col)
? ? (7)關(guān)閉
????????與IO流一樣,使用后的東西都需要關(guān)閉!關(guān)閉的順序是先得到的后關(guān)閉,后得到的先關(guān)閉。
????????????????rs.close();
????????????????stmt.close();
????????????????con.close();
? ? (8)代碼實(shí)現(xiàn)
package cn.yfy_01;import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement;import org.junit.Test;public class Demo1 {@Testpublic void fun1() throws ClassNotFoundException, SQLException {Class.forName("com.mysql.jdbc.Driver");String url = "jdbc:mysql://localhost:3306/mydbc";String username = "root";String password = "root";Connection con = DriverManager.getConnection(url, username, password);// 得到Statement對(duì)象Statement statement = con.createStatement();// 執(zhí)行SQL增刪改語(yǔ)句String sql = "insert into stu values('142074401','張三',23,'北京')";statement.executeUpdate(sql);System.out.println("插入數(shù)據(jù)成功");}@Testpublic void fun2() throws ClassNotFoundException, SQLException {Class.forName("com.mysql.jdbc.Driver");String url = "jdbc:mysql://localhost:3306/mydbc";String username = "root";String password = "root";Connection con = DriverManager.getConnection(url, username, password);// 得到Statement對(duì)象Statement statement = con.createStatement();// 執(zhí)行SQL查詢語(yǔ)句,得到ResultSet結(jié)果集String sql = "select * from stu";ResultSet rs = statement.executeQuery(sql);while (rs.next()) {// 查詢id值int id = rs.getInt("id");// 查詢第二列的值String name = rs.getString(2);// 查詢第三列的值int age = rs.getInt(3);// 查詢address的值String address = rs.getString("address");System.out.println(id + "," + name + "," + age + "," + address);}} }? ? (8)規(guī)范化代碼
????????所謂規(guī)范化代碼就是無(wú)論是否出現(xiàn)異常,都要關(guān)閉ResultSet、Statement,以及Connection。
@Testpublic void fun3() {Connection con = null;Statement statement = null;ResultSet rs = null;try {Class.forName("com.mysql.jdbc.Driver");String url = "jdbc:mysql://localhost:3306/mydbc";String username = "root";String password = "root";con = DriverManager.getConnection(url, username, password);statement = con.createStatement();String sql = "select * from stu";rs = statement.executeQuery(sql);while (rs.next()) {int id = rs.getInt("id");String name = rs.getString("name");int age = rs.getInt("age");String address = rs.getString("address");System.out.println(id + "," + name + "," + age + "," + address);}} catch (Exception e) {} finally {try {if (rs != null)rs.close();if (statement != null)statement.close();if (con != null)con.close();} catch (SQLException e) {e.printStackTrace();}}二、JDBC對(duì)象介紹
? ? 1.JDBC的主要類(接口)
????????在JDBC中常用的類有:
????????????DriverManager;
????????????Connection;
????????????Statement;
????????????ResultSet。
? ? 2.DriverManager
????????其實(shí)我們今后只需要會(huì)用DriverManager的getConnection()方法即可:
????????????????1.Class.forName(“com.mysql.jdbc.Driver”);//注冊(cè)驅(qū)動(dòng)
????????????????2.String url = “jdbc:mysql://localhost:3306/mydb1”;
????????????????3.String username = “root”
????????????????4.String password = “123”;
????????????????5.Connection con = DriverManager.getConnection(url, username, password);
?
????????注意,上面代碼可能出現(xiàn)的兩種異常:
????????????????1.ClassNotFoundException:這個(gè)異常是在第1句上出現(xiàn)的,出現(xiàn)這個(gè)異常有兩個(gè)可能:
????????????????????????你沒(méi)有給出mysql的jar包;
????????????????????????你把類名稱打錯(cuò)了,查看類名是不是com.mysql.jdbc.Driver。
????????????????2.SQLException:這個(gè)異常出現(xiàn)在第5句,出現(xiàn)這個(gè)異常就是三個(gè)參數(shù)的問(wèn)題,往往username和password一般不是出錯(cuò),所以需要認(rèn)真查看url是否打錯(cuò)。
?
????????對(duì)于DriverManager.registerDriver()方法了解即可,因?yàn)槲覀兘窈笞?cè)驅(qū)動(dòng)只會(huì)Class.forName(),而不會(huì)使用這個(gè)方法。
?
? ? 3.Connection
????????Connection最為重要的方法就是獲取Statement:
????????????????Statement stmt = con.createStatement();?
????? ? 該方法還有一個(gè)重載形式,后續(xù)會(huì)講解:
????????????????Statement stmt = con.createStatement(int,int);
? ? 4.Statement
????????Statement最為重要的方法是:
????????????????int executeUpdate(String sql):執(zhí)行更新操作,即執(zhí)行insert、update、delete語(yǔ)句,其實(shí)這個(gè)方法也可以執(zhí)行create table、alter table,以及drop table等語(yǔ)句,但我們很少會(huì)使用JDBC來(lái)執(zhí)行這些語(yǔ)句;
????????????????ResultSet executeQuery(String sql):執(zhí)行查詢操作,執(zhí)行查詢操作會(huì)返回ResultSet,即結(jié)果集。
??????????boolean execute():可以執(zhí)行executeUpdate()和executeQuery()兩個(gè)方法能執(zhí)行的sql語(yǔ)句
????????Statement還有一個(gè)boolean execute()方法,這個(gè)方法可以用來(lái)執(zhí)行增、刪、改、查所有SQL語(yǔ)句。該方法返回的是boolean類型,表示SQL語(yǔ)句是否有結(jié)果集!。
????????如果使用execute()方法執(zhí)行的是更新語(yǔ)句,那么還要調(diào)用int getUpdateCount()來(lái)獲取insert、update、delete語(yǔ)句所影響的行數(shù)。
????????如果使用execute()方法執(zhí)行的是查詢語(yǔ)句,那么還要調(diào)用ResultSet getResultSet()來(lái)獲取select語(yǔ)句的查詢結(jié)果。
? ? 5.ResultSet之滾動(dòng)結(jié)果集
????????ResultSet表示結(jié)果集,它是一個(gè)二維的表格!ResultSet內(nèi)部維護(hù)一個(gè)行光標(biāo)(游標(biāo)),ResultSet提供了一系列的方法來(lái)移動(dòng)游標(biāo):
void beforeFirst():把光標(biāo)放到第一行的前面,這也是光標(biāo)默認(rèn)的位置;
void afterLast():把光標(biāo)放到最后一行的后面;
boolean first():把光標(biāo)放到第一行的位置上,返回值表示調(diào)控光標(biāo)是否成功;
boolean last():把光標(biāo)放到最后一行的位置上;
?
boolean isBeforeFirst():當(dāng)前光標(biāo)位置是否在第一行前面;
boolean isAfterLast():當(dāng)前光標(biāo)位置是否在最后一行的后面;
boolean isFirst():當(dāng)前光標(biāo)位置是否在第一行上;
boolean isLast():當(dāng)前光標(biāo)位置是否在最后一行上;
?
boolean previous():把光標(biāo)向上挪一行;
boolean next():把光標(biāo)向下挪一行;
boolean relative(int row):相對(duì)位移,當(dāng)row為正數(shù)時(shí),表示向下移動(dòng)row行,為負(fù)數(shù)時(shí)表示向上移動(dòng)row行;
boolean absolute(int row):絕對(duì)位移,把光標(biāo)移動(dòng)到指定的行上;
int getRow():返回當(dāng)前光標(biāo)所有行。
?
????????獲取結(jié)果集元數(shù)據(jù)!
????????????????得到元數(shù)據(jù):rs.getMetaData(),返回值為ResultSetMetaData;
????????????????獲取結(jié)果集列數(shù):int getColumnCount()
? ? ? ? ? ? ? ? 獲取指定列的列名:String getColumnName(int colIndex)
????????結(jié)果集特性:當(dāng)使用Connection的createStatement時(shí),已經(jīng)確定了生成的結(jié)果集是什么特性。
????????????????是否可滾動(dòng)
????????????????是否敏感
? ? ? ? ? ? ? ? 是否可更新
????????con.createSttement():生成的結(jié)果集:不滾動(dòng)、不敏感、不可更新!
????????con.createStatement(int,int):
????????第一個(gè)參數(shù):
????????????????ResultSet.TYPE_FORWARD_ONLY:不滾動(dòng)結(jié)果集;
????????????????ResultSet.TYPE_SCROLL_INSENSITIVE:滾動(dòng)結(jié)果集,但結(jié)果集數(shù)據(jù)不會(huì)再跟隨數(shù)據(jù)庫(kù)而變化;
????????????????ResultSet.TYPE_SCROLL_SENSITIVE:滾動(dòng)結(jié)果集,但結(jié)果集數(shù)據(jù)不會(huì)再跟隨數(shù)據(jù)庫(kù)而變化;
? ? ? ? 第二個(gè)參數(shù):
????????????????CONCUR_READ_ONLY:結(jié)果集是只讀的,不能通過(guò)修改結(jié)果集而反向影響數(shù)據(jù)庫(kù);
????????????????CONCUR_UPDATABLE:結(jié)果集是可更新的,對(duì)結(jié)果集的更新可以反向影響數(shù)據(jù)庫(kù)。
????6、ResultSet獲取列數(shù)據(jù)
????????可以通過(guò)next()方法使ResultSet的游標(biāo)向下移動(dòng),當(dāng)游標(biāo)移動(dòng)到你需要的行時(shí),就需要來(lái)獲取該行的數(shù)據(jù)了,ResultSet提供了一系列的獲取列數(shù)據(jù)的方法:
????????????????String getString(int columnIndex):獲取指定列的String類型數(shù)據(jù);
????????????????int getInt(int columnIndex):獲取指定列的int類型數(shù)據(jù);
????????????????double getDouble(int columnIndex):獲取指定列的double類型數(shù)據(jù);
????????????????boolean getBoolean(int columnIndex):獲取指定列的boolean類型數(shù)據(jù);
????????????????Object getObject(int columnIndex):獲取指定列的Object類型的數(shù)據(jù)。
????????上面方法中,參數(shù)columnIndex表示列的索引,列索引從1開(kāi)始,而不是0,這第一點(diǎn)與數(shù)組不同。如果你清楚當(dāng)前列的數(shù)據(jù)類型,那么可以使用getInt()之類的方法來(lái)獲取,如果你不清楚列的類型,那么你應(yīng)該使用getObject()方法來(lái)獲取。
ResultSet還提供了一套通過(guò)列名稱來(lái)獲取列數(shù)據(jù)的方法:
????????????????String getString(String columnName):獲取名稱為columnName的列的String數(shù)據(jù);
????????????????int getInt(String columnName):獲取名稱為columnName的列的int數(shù)據(jù);
????????????????double getDouble(String columnName):獲取名稱為columnName的列的double數(shù)據(jù);
????????????????boolean getBoolean(String columnName):獲取名稱為columnName的列的boolean數(shù)據(jù);
? ? ? ? ? ? ? ? Object getObject(String columnName):獲取名稱為columnName的列的Object數(shù)據(jù);
三、PreparedStatement
? ? 1.什么是SQL攻擊
????????在需要用戶輸入的地方,用戶輸入的是SQL語(yǔ)句的片段,最終用戶輸入的SQL片段與我們DAO中寫(xiě)的SQL語(yǔ)句合成一個(gè)完整的SQL語(yǔ)句!例如用戶在登錄時(shí)輸入的用戶名和密碼都是為SQL語(yǔ)句的片段!
? ? 2.SQL攻擊代碼演示
首先創(chuàng)建一個(gè)表用來(lái)存儲(chǔ)用戶信息
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;寫(xiě)一個(gè)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("用戶名或密碼錯(cuò)誤!");}} catch (Exception e) {throw new RuntimeException(e);} finally {JdbcUtils.close(con, stmt, rs);} }調(diào)用這個(gè)方法
login("a' or 'a'='a", "a' or 'a'='a");????????最終會(huì)登陸成功。因?yàn)檩斎氲挠脩裘兔艽a是SQL語(yǔ)句片段,最終與我們的login()方法中的SQL語(yǔ)句組合在一起!
????SELECT * FROM tab_user WHERE username='a' or 'a'='a' and password='a' or 'a'='a'
? ? 3.防止SQL攻擊
????????過(guò)濾用戶輸入的數(shù)據(jù)中是否包含非法字符;
????????分步交驗(yàn)!先使用用戶名來(lái)查詢用戶,如果查找到了,再比較密碼;
????????使用PreparedStatement。
? ? 4.PreparedStatement是什么?
????????PreparedStatement叫預(yù)編譯聲明!
????????PreparedStatement是Statement的子接口,你可以使用PreparedStatement來(lái)替換Statement。
????????PreparedStatement的好處:
????????????????防止SQL攻擊;
????????????????提高代碼的可讀性,以可維護(hù)性;
????????????????提高效率。
? ? 5.PreparedStatement的使用
????? ? (1)使用Connection的prepareStatement(String sql):即創(chuàng)建它時(shí)就讓它與一條SQL模板綁定
????? ? (2)調(diào)用PreparedStatement的setXXX()系列方法為問(wèn)號(hào)設(shè)置值
????? ? (3)調(diào)用executeUpdate()或executeQuery()方法,但要注意,調(diào)用沒(méi)有參數(shù)的方法
String sql = “select * from tab_student where s_number=?”; PreparedStatement pstmt = con.prepareStatement(sql); pstmt.setString(1, “S_1001”); ResultSet rs = pstmt.executeQuery();????????在使用Connection創(chuàng)建PreparedStatement對(duì)象時(shí)需要給出一個(gè)SQL模板,所謂SQL模板就是有“?”的SQL語(yǔ)句,其中“?”就是參數(shù)。
????????在得到PreparedStatement對(duì)象后,調(diào)用它的setXXX()方法為“?”賦值,這樣就可以得到把模板變成一條完整的SQL語(yǔ)句,然后再調(diào)用PreparedStatement對(duì)象的executeQuery()方法獲取ResultSet對(duì)象。
????????注意PreparedStatement對(duì)象獨(dú)有的executeQuery()方法是沒(méi)有參數(shù)的,而Statement的executeQuery()是需要參數(shù)(SQL語(yǔ)句)的。因?yàn)樵趧?chuàng)建PreparedStatement對(duì)象時(shí)已經(jīng)讓它與一條SQL模板綁定在一起了,所以在調(diào)用它的executeQuery()和executeUpdate()方法時(shí)就不再需要參數(shù)了。
????????PreparedStatement最大的好處就是在于重復(fù)使用同一模板,給予其不同的參數(shù)來(lái)重復(fù)的使用它。這才是真正提高效率的原因。
四、JdbcUtils工具類
? ? 1.JdbcUtils的作用
????????連接數(shù)據(jù)庫(kù)的四大參數(shù)是:驅(qū)動(dòng)類、url、用戶名,以及密碼。這些參數(shù)都與特定數(shù)據(jù)庫(kù)關(guān)聯(lián),如果將來(lái)想更改數(shù)據(jù)庫(kù),那么就要去修改這四大參數(shù),那么為了不去修改代碼,我們寫(xiě)一個(gè)JdbcUtils類,讓它從配置文件中讀取配置參數(shù),然后創(chuàng)建連接對(duì)象。
? ? 2.JdbcUtils代碼
jdbcUtils.java
public class JdbcUtils {private static final String dbconfig = "dbconfig.properties";//配置文件路徑private static Properties prop = new Properties();//對(duì)應(yīng)配置文件static {try {InputStream in = Thread.currentThread().getContextClassLoader().getResourceAsStream(dbconfig);prop.load(in);Class.forName(prop.getProperty("driverClassName"));} catch(IOException e) {throw new RuntimeException(e);}}//獲取Connection方法,參數(shù)都是從prop中獲取。public static Connection getConnection() {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五、時(shí)間類型
????數(shù)據(jù)庫(kù)類型與java中類型的對(duì)應(yīng)關(guān)系:
????????DATE ?java.sql.Date
????????TIME ?java.sql.Time
????????TIMESTAMP ?java.sql.Timestamp
????????PreparedStatement#setDate(int, Date),其中第二個(gè)參數(shù)也是java.sql.Date
????領(lǐng)域?qū)ο?#xff08;domain)中的所有屬性不能出現(xiàn)java.sql包下的東西!即不能使用java.sql.Date;
????????ResultSet#getDate()返回的是java.sql.Date()
????時(shí)間類型的轉(zhuǎn)換:
????????java.util.Date 轉(zhuǎn)換為 java.sql.Date、Time、Timestamp
????? ? (1)把util的Date轉(zhuǎn)換成毫秒值
????? ? (2)使用毫秒值創(chuàng)建sql的Date、Time、Timestamp
java.util.Date date = new java.util.Date();long l = date.getTime();java.sql.Date sqlDate = new java.sql.Date(l);?
????????java.sql.Date、Time、Timestamp轉(zhuǎn)化為java.util.Date
?
????????? ? 不需要處理了:因?yàn)閖ava.sql.Date是java.util.Date的子類。
代碼演示:
創(chuàng)建一個(gè)dt表
CREATE TABLE dt(d DATE,t TIME,ts TIMESTAMP )向dt表中插入數(shù)據(jù)
@Testpublic 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表中查詢數(shù)據(jù)
@Testpublic 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);}六、大數(shù)據(jù)
? ? 1.什么是大數(shù)據(jù)
????????所謂大數(shù)據(jù),就是大的字節(jié)數(shù)據(jù),或大的字符數(shù)據(jù)。標(biāo)準(zhǔn)SQL中提供了如下類型來(lái)保存大數(shù)據(jù)類型:
????????但是,在mysql中沒(méi)有提供tinyclob、clob、mediumclob、longclob四種類型,而是使用如下四種類型來(lái)處理文本大數(shù)據(jù):
七、批處理
? ? 1.Statement批處理
????????批處理就是一批一批的處理,而不是一個(gè)一個(gè)的處理!
????????當(dāng)你有10條SQL語(yǔ)句要執(zhí)行時(shí),一次向服務(wù)器發(fā)送一條SQL語(yǔ)句,這么做效率上很差!處理的方案是使用批處理,即一次向服務(wù)器發(fā)送多條SQL語(yǔ)句,然后由服務(wù)器一次性處理。
????????批處理只針對(duì)更新(增、刪、改)語(yǔ)句,批處理沒(méi)有查詢什么事兒!
? ? ? ?可以多次調(diào)用Statement類的addBatch(String sql)方法,把需要執(zhí)行的所有SQL語(yǔ)句添加到一個(gè)“批”中,然后調(diào)用Statement類的executeBatch()方法來(lái)執(zhí)行當(dāng)前“批”中的語(yǔ)句。
????????void addBatch(String sql):添加一條語(yǔ)句到“批”中;
????????int[] executeBatch():執(zhí)行“批”中所有語(yǔ)句。返回值表示每條語(yǔ)句所影響的行數(shù)據(jù);
????????void clearBatch():清空“批”中的所有語(yǔ)句。
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.addBatch(sql);}stmt.executeBatch();?
????????當(dāng)執(zhí)行了“批”之后,“批”中的SQL語(yǔ)句就會(huì)被清空!也就是說(shuō),連續(xù)兩次調(diào)用executeBatch()相當(dāng)于調(diào)用一次!因?yàn)榈诙握{(diào)用時(shí),“批”中已經(jīng)沒(méi)有SQL語(yǔ)句了。
????????還可以在執(zhí)行“批”之前,調(diào)用Statement的clearBatch()方法來(lái)清空“批”!
? ? 2.PreparedStatement批處理
????????PreparedStatement的批處理有所不同,因?yàn)槊總€(gè)PreparedStatement對(duì)象都綁定一條SQL模板。所以向PreparedStatement中添加的不是SQL語(yǔ)句,而是給“?”賦值。
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");//PreparedStatement的addBatch()方法沒(méi)有參數(shù)!pstmt.addBatch();}pstmt.executeBatch();?
總結(jié)
- 上一篇: Java-Web JSTL标签库、
- 下一篇: jdbc入门(二)