Java使用JDBC連接數(shù)據(jù)庫(kù)
JDBC是由java編程語(yǔ)言編寫(xiě)的類(lèi)及接口組成,同時(shí)它為程序開(kāi)發(fā)人員提供了一組用于實(shí)現(xiàn)對(duì)數(shù)據(jù)庫(kù)訪問(wèn)的JDBC API,并支持SQL語(yǔ)言。利用JDBC可以將JAVA代碼連接到oracle、DB2、SQLServer、MYSQL等數(shù)據(jù)庫(kù),從而實(shí)現(xiàn)對(duì)數(shù)據(jù)庫(kù)中的數(shù)據(jù)操作的目的。
一、JDBC簡(jiǎn)介
JDBC全稱(chēng)為:Java Data Base Connectivity (java數(shù)據(jù)庫(kù)連接),可以為多種數(shù)據(jù)庫(kù)提供填統(tǒng)一的訪問(wèn)。JDBC是sun開(kāi)發(fā)的一套數(shù)據(jù)庫(kù)訪問(wèn)編程接口,是一種SQL級(jí)的API。它是由java語(yǔ)言編寫(xiě)完成,所以具有很好的跨平臺(tái)特性,使用JDBC編寫(xiě)的數(shù)據(jù)庫(kù)應(yīng)用程序可以在任何支持java的平臺(tái)上運(yùn)行,而不必在不同的平臺(tái)上編寫(xiě)不同的應(yīng)用程序。
JDBC的主要功能如下:
- (1)建立與數(shù)據(jù)庫(kù)或者其他數(shù)據(jù)源的鏈接
- (2)向數(shù)據(jù)庫(kù)發(fā)送SQL命令
- (3)處理數(shù)據(jù)庫(kù)的返回結(jié)果
二、JDBC中常用類(lèi)和接口
連接到數(shù)據(jù)庫(kù)(Connection)、建立操作指令(Statement)、執(zhí)行查詢指令(executeQuery)、獲得查詢結(jié)果(ResultSet)等。
1、驅(qū)動(dòng)程序管理類(lèi)(DriverManager)
DriverManager類(lèi)是JDBC的管理類(lèi),作用于用戶和驅(qū)動(dòng)程序之間。它跟蹤在可用的驅(qū)動(dòng)程序,并在數(shù)據(jù)庫(kù)和相應(yīng)驅(qū)動(dòng)程序之間建立連接。另外,DriverManager類(lèi)也處理諸如驅(qū)動(dòng)程序登陸時(shí)間限制及登錄和跟蹤消息的顯示事務(wù)。對(duì)于簡(jiǎn)單的應(yīng)用程序,一般程序員需要在此類(lèi)中直接使用唯一的方法時(shí)DriverManager.getConnection()。該方法將建立與數(shù)據(jù)庫(kù)的鏈接。JDBC允許用戶調(diào)用DriverManager的方法getDriver()、getDrivers()和registerDriver()及Driver的方法connect().
2、聲明類(lèi)(Statement)
Statement對(duì)象用于將SQL語(yǔ)句發(fā)送到數(shù)據(jù)庫(kù)中。實(shí)際上有三種Statement對(duì)象,它們都作為在給定鏈接上執(zhí)行SQL語(yǔ)句的包容器:Statement、PreparedStatement(它從Statement繼承而來(lái))和CallableStatement(它從PreparedStatement繼承而來(lái))。它們都專(zhuān)用于發(fā)送特定類(lèi)型的SQL語(yǔ)句:
- (1)Statement對(duì)象用于執(zhí)行不帶參數(shù)的簡(jiǎn)單的SQL語(yǔ)句;Statement接口提供了執(zhí)行語(yǔ)句和獲取結(jié)果的基本方法。
- (2)PerparedStatement對(duì)象用于執(zhí)行帶或不帶IN參數(shù)的預(yù)編譯SQL語(yǔ)句;PeraredStatement接口添加處理IN參數(shù)的方法;
- (3)CallableStatement對(duì)象用于執(zhí)行對(duì)數(shù)據(jù)庫(kù)已存儲(chǔ)過(guò)程的調(diào)用;CallableStatement添加處理OUT參數(shù)的方法。
Statement提供了許多方法,最常用的方法如下:
- (1)execute()方法:運(yùn)行語(yǔ)句,返回是否有結(jié)果集。
- (2)executeQuery()方法:運(yùn)行查詢語(yǔ)句,返回ReaultSet對(duì)象。
- (3)executeUpdata()方法:運(yùn)行更新操作,返回更新的行數(shù)。
- (4)addBatch()方法:增加批處理語(yǔ)句。
- (5)executeBatch()方法:執(zhí)行批處理語(yǔ)句。
- (6)clearBatch()方法:清除批處理語(yǔ)句
3、數(shù)據(jù)庫(kù)連接類(lèi) (Connection)
Connection對(duì)象代表與數(shù)據(jù)庫(kù)的鏈接。連接過(guò)程包括所執(zhí)行的SQL語(yǔ)句和在該連接上所返回的結(jié)果。一個(gè)應(yīng)用程序可與單個(gè)數(shù)據(jù)庫(kù)有一個(gè)或多個(gè)連接,或者可與很多數(shù)據(jù)庫(kù)有連接。打開(kāi)連接與數(shù)據(jù)庫(kù)建立連接的標(biāo)準(zhǔn)方法是調(diào)用DriverManager.getConnection()方法。
String url="jdbc:mysql://127.0.0.1:3306/imooc";
String user="root";
String password="tiger";
DriverManager.getConnection(url,user,password);
4、結(jié)果集合類(lèi) (ResultSet)
ResultSet包含符合SQL語(yǔ)句中條件的所有行記錄,并且它通過(guò)一套get方法(這些get方法可以訪問(wèn)當(dāng)前行中的不同列)提供了對(duì)這些行中數(shù)據(jù)的訪問(wèn)。ResultSet.next()方法用于移動(dòng)到ResultSet中的下一行,使下一行成為當(dāng)前行。
5、JDBC編程步驟
- (1)加載驅(qū)動(dòng)程序:Class.forName(driverClass)
加載mysql驅(qū)動(dòng):Class.forName("com.mysql.jdbc.Driver");
加載oracle驅(qū)動(dòng):Class.forName("oracle.jdbc.driver.OracleDriver");
- (2)獲得數(shù)據(jù)庫(kù)連接
DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/imooc",user,password);
DriverManager.gerConnection(URL,user,password);
- (3)創(chuàng)建Statement對(duì)象:conn.createStatement();
- (4)向數(shù)據(jù)庫(kù)發(fā)送SQL命令
- (5)處理數(shù)據(jù)庫(kù)的返回結(jié)果(ResultSet類(lèi))
?代碼演示:
import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) Statement st=conn.createStatement(); ResultSet rs=st.executeQuery("select * from user"); //4.處理數(shù)據(jù)庫(kù)的返回結(jié)果(使用ResultSet類(lèi)) while(rs.next()){ System.out.println(rs.getString("user_name")+" " +rs.getString("user_password")); } //關(guān)閉資源 rs.close(); st.close(); conn.close(); } }
運(yùn)行結(jié)果:
1 xiao 123 2 lo 123 3 小孩 123 4 校長(zhǎng) 123 5 xiaol 123
三、常用操作(對(duì)于記錄來(lái)說(shuō))
JDBC可以實(shí)現(xiàn)SQL語(yǔ)句在數(shù)據(jù)庫(kù)中的執(zhí)行,也就是說(shuō),數(shù)據(jù)庫(kù)的所有操作,包括對(duì)數(shù)據(jù)庫(kù),對(duì)表格,對(duì)記錄都可以進(jìn)行相應(yīng)的操作,但是其實(shí)原則上,JDBC只應(yīng)該對(duì)記錄進(jìn)行操作,不能對(duì)表格乃至數(shù)據(jù)庫(kù)進(jìn)行更改操作。下面只介紹對(duì)記錄的操作。
1.獲取數(shù)據(jù)庫(kù)連接
一般為了方便建立數(shù)據(jù)庫(kù)鏈接通常會(huì)創(chuàng)建一個(gè)類(lèi),里面封裝好實(shí)現(xiàn)數(shù)據(jù)庫(kù)鏈接的函數(shù),方便調(diào)用實(shí)現(xiàn)數(shù)據(jù)庫(kù)連接。
import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class DBUtil { private static final String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; private static final String USER="root"; private static final String PASSWORD="tiger"; private static Connection conn=null; static { try { //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)的連接 conn=DriverManager.getConnection(URL, USER, PASSWORD); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } } //將獲得的數(shù)據(jù)庫(kù)與java的鏈接返回(返回的類(lèi)型為Connection) public static Connection getConnection(){ return conn; } }
2、增加表中記錄
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s=""+"insert into user(id,user_name,user_password) values("+"2,?,123)"; PreparedStatement pst=conn.prepareStatement(s); pst.setString(1, "xiaoshuai1"); //pst.setString(2, "123"); pst.execute(); //關(guān)閉資源 pst.close(); conn.close(); } }
3、刪除數(shù)據(jù)庫(kù)表格記錄
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="delete from user where id=2 and user_name=?"; PreparedStatement pst=conn.prepareStatement(s); pst.setString(1, "xiaoshuai1"); //pst.setString(2, "123"); pst.execute(); //關(guān)閉資源 pst.close(); conn.close(); } }
4、更新數(shù)據(jù)庫(kù)中表格記錄信息
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="update user set user_name=? where id=1 "; PreparedStatement pst=conn.prepareStatement(s); pst.setString(1, "xiaoshuaige"); //pst.setString(2, "123"); pst.execute(); //關(guān)閉資源 pst.close(); conn.close(); } }
5、查詢
(1)單個(gè)變量的查詢
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="select user_name,user_password from user where user_name=? and user_password=?"; PreparedStatement pst=conn.prepareStatement(s); pst.setString(1, "xiao"); pst.setString(2, "123"); ResultSet rs=pst.executeQuery(); //4.處理數(shù)據(jù)庫(kù)的返回結(jié)果(使用ResultSet類(lèi)) while(rs.next()){ System.out.println(rs.getString("user_name")+" " +rs.getString("user_password")); } //關(guān)閉資源 rs.close(); pst.close(); conn.close(); } }
運(yùn)行結(jié)果:
xiao 123
特別注意當(dāng)正則表達(dá)式形如:select ?,? from user時(shí),要特別注意,查詢的結(jié)果并不是自己想要查詢的結(jié)果
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="select ?,? from user where user_name=xiao and user_password=123"; PreparedStatement pst=conn.prepareStatement(s); pst.setString(1, "user_name"); pst.setString(2, "user_password"); ResultSet rs=pst.executeQuery(); //4.處理數(shù)據(jù)庫(kù)的返回結(jié)果(使用ResultSet類(lèi)) System.out.println(rs.getString("user_name")+" " +rs.getString("user_password")); //關(guān)閉資源 rs.close(); pst.close(); conn.close(); } }
運(yùn)行結(jié)果:
1 user_name user_password
(2)多個(gè)變量查詢
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="select user_name,user_password from user where 1=1"; PreparedStatement pst=conn.prepareStatement(s); /*pst.setString(1, "xiao"); pst.setString(2, "123");*/ /*pst.setString(1, "user_name"); pst.setString(2, "user_password");*/ ResultSet rs=pst.executeQuery(); //4.處理數(shù)據(jù)庫(kù)的返回結(jié)果(使用ResultSet類(lèi)) while(rs.next()){ System.out.println(rs.getString("user_name")+" " +rs.getString("user_password")); } //關(guān)閉資源 rs.close(); pst.close(); conn.close(); } }
運(yùn)行結(jié)果:
xiao 123 xiaod 123 xiaok 123 xiao1 123 xo 122 po 123 xio 123 lo 123 小孩 123 校長(zhǎng) 123 xiaol 123
6、調(diào)用存儲(chǔ)過(guò)程
(1)調(diào)用無(wú)參存儲(chǔ)過(guò)程
1)存儲(chǔ)過(guò)程代碼
CREATE PROCEDURE SP_select_nofilter3() BEGIN SELECT * FROM file; END;
2)調(diào)用代碼
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="call SP_select_nofilter3() "; CallableStatement cst=conn.prepareCall(s); ResultSet rs=cst.executeQuery(); while(rs.next()){ System.out.println(rs.getString("user_name")); } //關(guān)閉資源 cst.close(); conn.close(); } }
運(yùn)行結(jié)果:
1 xiao 2 xiao 3 xiao 4 xiao
(2)調(diào)用含有IN參數(shù)的存儲(chǔ)過(guò)程
1)存儲(chǔ)過(guò)程代碼
CREATE PROCEDURE SP_select_nofilter4(IN SP_name varchar(20)) BEGIN IF SP_name=null OR SP_name=' ' THEN SELECT * FROM file; ELSE SELECT * FROM file WHERE user_name=SP_name; END IF; END;
2)調(diào)用代碼:
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) /*查詢不帶參數(shù)*/ String s="call SP_select_nofilter4(?) "; CallableStatement cst=conn.prepareCall(s); cst.setString(1," "); ResultSet rs=cst.executeQuery(); while(rs.next()){ System.out.println(rs.getString("id")+" "+rs.getString("user_name")); } System.out.println("*******************************"); //查詢帶參數(shù) String s1="call SP_select_nofilter4(?)"; CallableStatement cst1=conn.prepareCall(s1); cst1.setString(1, "xiao1"); ResultSet rs1=cst1.executeQuery(); while(rs1.next()){ System.out.println(rs1.getString("id")+" "+rs1.getString("user_name")); } //關(guān)閉資源 rs1.close(); cst1.close(); rs.close(); cst.close(); conn.close(); } }
運(yùn)行結(jié)果:
1 xiao 2 xiao 3 xiao 4 xiao1 ******************************* 4 xiao1
(3)調(diào)用含有OUT參數(shù)存儲(chǔ)過(guò)程
1)存儲(chǔ)過(guò)程代碼
CREATE PROCEDURE SP_select_nofilter5(OUT SP_name varchar(20)) BEGIN SELECT user_name INTO SP_name FROM file WHERE id=2; END;
2)調(diào)用代碼:
import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Types; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="call SP_select_nofilter5(?) "; CallableStatement cst=conn.prepareCall(s); cst.registerOutParameter(1, Types.VARCHAR); ResultSet rs=cst.executeQuery(); String name=cst.getString(1); System.out.println(name); //關(guān)閉資源 rs.close(); cst.close(); conn.close(); } }
運(yùn)行結(jié)果:
xiao
(4)既含IN又含OUT參數(shù)的存儲(chǔ)過(guò)程
1)存儲(chǔ)過(guò)程代碼
CREATE PROCEDURE SP_select_nofilter6(OUT SP_name varchar(20),IN id1 int,OUT path1 BLOB) BEGIN SELECT path , user_name INTO path1, SP_name FROM file WHERE id=id1; END;
2)代碼調(diào)用
public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) String s="call SP_select_nofilter6(?,?,?) "; CallableStatement cst=conn.prepareCall(s); cst.setInt(2, 2); cst.registerOutParameter(1, Types.VARCHAR); cst.registerOutParameter(3, Types.BLOB); ResultSet rs=cst.executeQuery(); String name=cst.getString(1); Blob b=cst.getBlob(3); System.out.println("name:"+name+" Blob:"+b); //關(guān)閉資源 rs.close(); cst.close(); conn.close(); } }
運(yùn)行結(jié)果:
name:xiao Blob:com.mysql.jdbc.Blob@3941a79c
四、事務(wù)
事務(wù)(Transaction)是作為單個(gè)邏輯工作單位執(zhí)行的一系列操作,這些操作作為一個(gè)整體一起向系統(tǒng)提交,要么都執(zhí)行,要么都不執(zhí)行。
1、事務(wù)的特點(diǎn)
- (1)原子性:事務(wù)是一個(gè)完整的操作
- (2)一致性:當(dāng)食物完成時(shí),數(shù)據(jù)必須處于一致?tīng)顟B(tài)
- (3)隔離性:對(duì)數(shù)據(jù)進(jìn)行修改的所有兵法事務(wù)彼此隔離
- (4)永久性:事務(wù)完成后,它對(duì)數(shù)據(jù)庫(kù)的修改被永久的保存
2、JDBC對(duì)事務(wù)管理的支持
- (1)我們通過(guò)提交Commit()或是回退rollback()來(lái)管理事務(wù)的操作
- (2)事務(wù)操作默認(rèn)是自動(dòng)提交的
- (3)可以通過(guò)調(diào)用setAutoCommit(false)來(lái)禁止自動(dòng)提交。
3、批處理
1、批處理規(guī)范
JDBC升級(jí)到2.0后增強(qiáng)了statement接口,使它能夠以批處理的方式執(zhí)行更新操作(select等語(yǔ)句不能使用)。批處理操作指的是一次可以提交多句更新語(yǔ)句,這些更新語(yǔ)句一起執(zhí)行。批處理相對(duì)逐句提交,使性能大幅度提高。它的具體步驟如下:
conn.setAutoCommit(false); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) Statement st=conn.createStatement(); st.addBatch("insert into user(user_name,user_password) values('小時(shí)2','456')"); st.addBatch("insert into user(user_name,user_password) values('小時(shí)3','4561')"); st.executeBatch(); conn.commit();
2、批處理舉例
package test; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.sql.Types; import java.sql.Blob; import java.sql.CallableStatement; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class javaTest { public static void main(String[] args) throws ClassNotFoundException, SQLException { String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8"; String USER="root"; String PASSWORD="tiger"; //1.加載驅(qū)動(dòng)程序 Class.forName("com.mysql.jdbc.Driver"); //2.獲得數(shù)據(jù)庫(kù)鏈接 Connection conn=DriverManager.getConnection(URL, USER, PASSWORD); //設(shè)置事務(wù)不自動(dòng)提交 conn.setAutoCommit(false); //3.通過(guò)數(shù)據(jù)庫(kù)的連接操作數(shù)據(jù)庫(kù),實(shí)現(xiàn)增刪改查(使用Statement類(lèi)) Statement st=conn.createStatement(); st.addBatch("insert into user(user_name,user_password) values('小時(shí)2','456')"); st.addBatch("insert into user(user_name,user_password) values('小時(shí)3','4561')"); st.executeBatch(); conn.commit(); //關(guān)閉資源 st.close(); conn.close(); } }
以上所述是小編給大家介紹的Java使用JDBC連接數(shù)據(jù)庫(kù),希望對(duì)大家有所幫助。在此也非常感謝大家對(duì)腳本之家網(wǎng)站的支持!
相關(guān)文章
Java入門(mén)教程--帶包的類(lèi)如何編譯與運(yùn)行
我們一般都是通過(guò)IDE(如Eclipse、Intellij Idea,STS等)來(lái)開(kāi)發(fā),調(diào)試java項(xiàng)目。在不借助IDE的情況下,如何編譯、運(yùn)行Java程序。打包編譯時(shí),會(huì)自動(dòng)創(chuàng)建包目錄,不需要自己新建包名文件夾。2022-12-12淺談String類(lèi)型等值比較引起的“==”、“equals()”和“hashCode”思考
這篇文章主要介紹了淺談String類(lèi)型等值比較引起的“==”、“equals()”和“hashCode”思考。具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-09-09MyBatis一級(jí)與二級(jí)緩存相關(guān)配置
mybatis-plus是一個(gè)Mybatis的增強(qiáng)工具,在Mybatis的基礎(chǔ)上只做增強(qiáng)不做改變,為簡(jiǎn)化開(kāi)發(fā)、提高效率而生,這篇文章帶你了解Mybatis的一級(jí)和二級(jí)緩存2023-01-01mybatisPlus自動(dòng)填充更新時(shí)間的示例代碼
本文主要介紹了mybatisPlus自動(dòng)填充更新時(shí)間,文中通過(guò)示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2021-09-09Java程序啟動(dòng)時(shí)初始化數(shù)據(jù)的四種方式
本文主要介紹了Java程序啟動(dòng)時(shí)初始化數(shù)據(jù)的四種方式,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2024-02-02關(guān)于HttpServletRequest獲取POST請(qǐng)求Body參數(shù)的3種方式
這篇文章主要介紹了關(guān)于HttpServletRequest獲取POST請(qǐng)求Body參數(shù)的3種方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2023-11-11SpringBoot實(shí)現(xiàn)異步事件驅(qū)動(dòng)的方法
本文主要介紹了SpringBoot實(shí)現(xiàn)異步事件驅(qū)動(dòng)的方法,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-06-06Mybatis-Plus集成Sharding-JDBC與Flyway實(shí)現(xiàn)多租戶分庫(kù)分表實(shí)戰(zhàn)
這篇文章主要為大家介紹了Mybatis-Plus集成Sharding-JDBC與Flyway實(shí)現(xiàn)多租戶分庫(kù)分表實(shí)戰(zhàn),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-11-11