JDBC 表示java的數(shù)據(jù)庫連接，提供一套完整的訪問數(shù)據(jù)庫的接口。JDBC由兩層體系構(gòu)成
- JDBC Api 提供了應(yīng)用程序?qū)DBC的管理連接。
- JDBC Driver支持JDBC管理到驅(qū)動器連接
JDBC組件
JDBC API提供了以下接口和類：
DriverManager: 這個(gè)類管理數(shù)據(jù)庫驅(qū)動程序的列表。內(nèi)容是否符合從Java應(yīng)用程序使用的通信子協(xié)議正確的數(shù)據(jù)庫驅(qū)動程序的連接請求。識別JDBC在一定子協(xié)議的第一個(gè)驅(qū)動器將被用來建立數(shù)據(jù)庫連接。
Driver: 此接口處理與數(shù)據(jù)庫服務(wù)器通信。很少直接與驅(qū)動程序?qū)ο?。相反，使用DriverManager中的對象，它管理此類型的對象。它也抽象與驅(qū)動程序?qū)ο蠊ぷ飨嚓P(guān)的詳細(xì)信息
Connection : 此接口與接觸數(shù)據(jù)庫的所有方法。連接對象表示通信上下文，即，與數(shù)據(jù)庫中的所有的通信是通過唯一的連接對象。
Statement : 可以使用這個(gè)接口創(chuàng)建的對象的SQL語句提交到數(shù)據(jù)庫。一些派生的接口接受除執(zhí)行存儲過程的參數(shù)。
boolean execute(String SQL) : 返回一個(gè)布爾值true，如果ResultSet對象可以被檢索，否則返回false。使用這個(gè)方法來執(zhí)行SQL DDL語句，或當(dāng)需要使用真正的動態(tài)SQL。
int executeUpdate(String SQL) : 返回受影響的SQL語句執(zhí)行的行數(shù)。使用此方法來執(zhí)行，而希望得到一些受影響的行的SQL語句 - 例如，INSERT，UPDATE或DELETE語句。
ResultSet executeQuery(String SQL) :返回ResultSet對象。當(dāng)希望得到一個(gè)結(jié)果集使用此方法，就像使用一個(gè)SELECT語句。
ResultSet: 這些對象保存從數(shù)據(jù)庫后，執(zhí)行使用Statement對象的SQL查詢中檢索數(shù)據(jù)。它作為一個(gè)迭代器，讓您可以通過移動它的數(shù)據(jù)。
SQLException: 這個(gè)類處理發(fā)生在一個(gè)數(shù)據(jù)庫應(yīng)用程序的任何錯(cuò)誤。
加載驅(qū)動
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();
// 動態(tài)SQL
PreparedStatement
// 存儲過程
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();}