JDBC 表示java的數(shù)據(jù)庫(kù)連接,提供一套完整的訪問(wèn)數(shù)據(jù)庫(kù)的接口。JDBC由兩層體系構(gòu)成
- JDBC Api 提供了應(yīng)用程序?qū)DBC的管理連接柱宦。
- JDBC Driver支持JDBC管理到驅(qū)動(dòng)器連接
JDBC組件
JDBC API提供了以下接口和類(lèi):
DriverManager: 這個(gè)類(lèi)管理數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序的列表熬丧。內(nèi)容是否符合從Java應(yīng)用程序使用的通信子協(xié)議正確的數(shù)據(jù)庫(kù)驅(qū)動(dòng)程序的連接請(qǐng)求。識(shí)別JDBC在一定子協(xié)議的第一個(gè)驅(qū)動(dòng)器將被用來(lái)建立數(shù)據(jù)庫(kù)連接探入。
Driver: 此接口處理與數(shù)據(jù)庫(kù)服務(wù)器通信。很少直接與驅(qū)動(dòng)程序?qū)ο蠖O喾捶渌裕褂肈riverManager中的對(duì)象,它管理此類(lèi)型的對(duì)象殃恒。它也抽象與驅(qū)動(dòng)程序?qū)ο蠊ぷ飨嚓P(guān)的詳細(xì)信息
Connection : 此接口與接觸數(shù)據(jù)庫(kù)的所有方法植旧。連接對(duì)象表示通信上下文,即离唐,與數(shù)據(jù)庫(kù)中的所有的通信是通過(guò)唯一的連接對(duì)象病附。
Statement : 可以使用這個(gè)接口創(chuàng)建的對(duì)象的SQL語(yǔ)句提交到數(shù)據(jù)庫(kù)。一些派生的接口接受除執(zhí)行存儲(chǔ)過(guò)程的參數(shù)亥鬓。
boolean execute(String SQL) : 返回一個(gè)布爾值true完沪,如果ResultSet對(duì)象可以被檢索,否則返回false嵌戈。使用這個(gè)方法來(lái)執(zhí)行SQL DDL語(yǔ)句覆积,或當(dāng)需要使用真正的動(dòng)態(tài)SQL。
int executeUpdate(String SQL) : 返回受影響的SQL語(yǔ)句執(zhí)行的行數(shù)熟呛。使用此方法來(lái)執(zhí)行宽档,而希望得到一些受影響的行的SQL語(yǔ)句 - 例如,INSERT庵朝,UPDATE或DELETE語(yǔ)句吗冤。
ResultSet executeQuery(String SQL) :返回ResultSet對(duì)象。當(dāng)希望得到一個(gè)結(jié)果集使用此方法偿短,就像使用一個(gè)SELECT語(yǔ)句欣孤。
ResultSet: 這些對(duì)象保存從數(shù)據(jù)庫(kù)后,執(zhí)行使用Statement對(duì)象的SQL查詢中檢索數(shù)據(jù)昔逗。它作為一個(gè)迭代器降传,讓您可以通過(guò)移動(dòng)它的數(shù)據(jù)。
SQLException: 這個(gè)類(lèi)處理發(fā)生在一個(gè)數(shù)據(jù)庫(kù)應(yīng)用程序的任何錯(cuò)誤勾怒。
加載驅(qū)動(dòng)
Class.forName("com.mysql.jdbc.Driver");
建立連接
Connection conn = DriverManager.getConnection("jdbc:mysql://192.168.33.10:3306/tbl_user", "root", "root");
創(chuàng)建聲明
// 靜態(tài) SQL statement
Statement stmt = conn.createStatement();
// 動(dòng)態(tài)SQL
PreparedStatement
// 存儲(chǔ)過(guò)程
CallableStatement
執(zhí)行操作
ResultSet rs = stmt.executeQuery("select * from user");
處理結(jié)果
while (rs.next()) {
System.out.print(rs.getString("name"));
}
關(guān)閉連接
rs.close();
stmt.close();
conn.close();
操作記錄
private static void createTable(Connection conn) throws SQLException {
String sql = "CREATE TABLE tb_user " +
"(id INTEGER not NULL, " +
" name VARCHAR(255), " +
" pass VARCHAR(255), " +
" age INTEGER, " +
" PRIMARY KEY ( id ))";
Statement s = conn.createStatement();
s.executeUpdate(sql);
System.out.print("create table success");
s.close();}
private static void insertData(Connection conn) throws SQLException {
String sql = "insert into tb_user " +
"values(1000, 'huben', '123456', 25)";
Statement s = conn.createStatement();
s.executeUpdate(sql);
s.close();}
private static void getData(Connection conn) throws SQLException {
Statement s = conn.createStatement();
ResultSet rs = s.executeQuery("select * from tb_user");
while (rs.next()) {
System.out.print(rs.getString("name")+":" + rs.getString("pass") +":"+ rs.getInt("age"));
}}
private static void update(Connection conn) throws SQLException {
PreparedStatement ps = conn.prepareStatement("update tb_user set name = ?, pass = ?, age = ? where id = ?");
ps.setObject(1, "zhangsan");
ps.setObject(2, "654321");
ps.setObject(3, 20);
ps.setInt(4, 1000);
ps.executeUpdate();}
private static void delete(Connection conn) throws SQLException {
PreparedStatement ps = conn.prepareStatement("delete from tb_user where id = ?");
ps.setInt(1, 1000);
ps.executeUpdate();}