萬盛學電腦網

 萬盛學電腦網 >> 數據庫 >> mysql教程 >> 詳解通過JDBC進行簡單的增刪改查(以MySQL為例)

詳解通過JDBC進行簡單的增刪改查(以MySQL為例)

小編推薦的這篇文章詳解通過JDBC進行簡單的增刪改查(以MySQL為例)的教程,非常有用,希望能幫助到有需要的同學。

前言:什麼是JDBC

Java 數據庫連接,(Java Database  Connectivity,簡稱JDBC)是Java語言中用來規范客戶端程序如何來訪問數據庫的應用程序接口,提供了諸如查詢和更新數據庫中數據的方法。JDBC也是Sun  Microsystems的商標。它JDBC是面向關系型數據庫的。

簡單地說,就是用於執行SQL語句的一類Java API,通過JDBC使得我們可以直接使用Java編程來對關系數據庫進行操作。通過封裝,可以使開發人員使用純Java API完成SQL的執行。

一、准備工作(一):MySQL安裝配置和基礎學習

使用JDBC操作數據庫之前,首先你需要有一個數據庫。這裡提供了3個鏈接供讀者自學,如果曾有過SQL語言的使用經歷(包括在學校中的課堂學習),前兩個鏈接足以上手。

Mysql下載安裝、部署與圖形化詳細操作教程:http://www.jb51.net/article/87690.htm

建議邊看入門教程,邊練習,在練習insert、update、select、delete等基本操作的同時,將後面要用的表建好。

下圖是我接下來用於演示的數據庫的表。

   

 二、准備工作(二):下載數據庫對應的jar包並導入

使用JDBC需要在工程中導入對應的jar包。數據庫與JDBC包的對應關系可以參考各種數據庫對應的jar包、驅動類名和URL格式。在Eclipse下的導入方法:

在工程的圖標上右擊,選擇”Properties”,在”Java Bulid Path”中選擇”Add External JARs…”,選擇下載並解壓後獲得的jar包。

       

如果對MySQL進行操作,這時下面的import就不會報錯了:

importcom.mysql.jdbc.Connection;

importcom.mysql.jdbc.PreparedStatement;

除此以外,還需要JDBC的包,直接import即可。

importjava.sql.DriverManager;

importjava.sql.ResultSet;

importjava.sql.SQLException;

三、JDBC基本操作

為了簡單起見,與數據庫相關的操作、命令、參數都被硬編碼了。有興趣的讀者可以對這些進行探索,降低數據與操作的耦合性。

先看具體代碼並實踐,本文第五部分對用到的API稍作了研究。

下面的所有方法和數據成員都在public class JDBCOperation內部。

(1)定義記錄的類(可選)

這樣做主要是為了便於操作和接口定義,是非必須的。

staticclassStudent {

  privateString Id;

  privateString Name;

  privateString Sex;

  privateString Age;

 

  Student(String Name, String Sex, String Age) {

   this.Id =null;//default

   this.Name = Name;

   this.Sex = Sex;

   this.Age = Age;

  }

 

  publicString getId() {

   returnId;

  }

 

  publicvoidsetId(String Id) {

   this.Id = Id;

  }

 

  publicString getName() {

   returnName;

  }

 

  publicvoidsetName(String Name) {

   this.Name = Name;

  }

 

  publicString getSex() {

   returnSex;

  }

 

  publicvoidsetSex(String Sex) {

   this.Sex = Sex;

  }

 

  publicString getAge() {

   returnAge;

  }

 

  publicvoidsetage(String Age) {

   this.Age = Age;

  }

}

(2)連接的獲取

在操作前必須先獲取與數據庫的連接。

privatestaticConnection getConn() {

 String driver ="com.mysql.jdbc.Driver";

 String url ="jdbc:mysql://localhost:3306/samp_db";

 String username ="root";

 String password ="";

 Connection conn =null;

 try{

  Class.forName(driver);//classLoader,加載對應驅動

  conn = (Connection) DriverManager.getConnection(url, username, password);

 }catch(ClassNotFoundException e) {

  e.printStackTrace();

 }catch(SQLException e) {

  e.printStackTrace();

 }

 returnconn;

}

(3)insert

privatestaticintinsert(Student student) {

 Connection conn = getConn();

 inti =0;

 String sql ="insert into students (Name,Sex,Age) values(?,?,?)";

 PreparedStatement pstmt;

 try{

  pstmt = (PreparedStatement) conn.prepareStatement(sql);

  pstmt.setString(1, student.getName());

  pstmt.setString(2, student.getSex());

  pstmt.setString(3, student.getAge());

  i = pstmt.executeUpdate();

  pstmt.close();

  conn.close();

 }catch(SQLException e) {

  e.printStackTrace();

 }

 returni;

}

(4)update

privatestaticintupdate(Student student) {

 Connection conn = getConn();

 inti =0;

 String sql ="update students set Age='"+ student.getAge() +"' where Name='"+ student.getName() +"'";

 PreparedStatement pstmt;

 try{

  pstmt = (PreparedStatement) conn.prepareStatement(sql);

  i = pstmt.executeUpdate();

  System.out.println("resutl: "+ i);

  pstmt.close();

  conn.close();

 }catch(SQLException e) {

  e.printStackTrace();

 }

 returni;

}

(5)select

以select * from XXX為例。

privatestaticInteger getAll() {

 Connection conn = getConn();

 String sql ="select * from students";

 PreparedStatement pstmt;

 try{

  pstmt = (PreparedStatement)conn.prepareStatement(sql);

  ResultSet rs = pstmt.executeQuery();

  intcol = rs.getMetaData().getColumnCount();

  System.out.println("============================");

  while(rs.next()) {

   for(inti =1; i <= col; i++) {

    System.out.print(rs.getString(i) +"\t");

    if((i ==2) && (rs.getString(i).length()<8)) {

     System.out.print("\t");

    }

    }

   System.out.println("");

  }

   System.out.println("============================");

 }catch(SQLException e) {

  e.printStackTrace();

 }

 returnnull;

}

(6)delete

privatestaticintdelete(String name) {

 Connection conn = getConn();

 inti =0;

 String sql ="delete from students where Name='"+ name +"'";

 PreparedStatement pstmt;

 try{

  pstmt = (PreparedStatement) conn.prepareStatement(sql);

  i = pstmt.executeUpdate();

  System.out.println("resutl: "+ i);

  pstmt.close();

  conn.close();

 }catch(SQLException e) {

  e.printStackTrace();

 }

 returni;

}

四、測試

在測試前,需要在系統中打開對應數據庫的服務。MySQL在Windows下的啟動命令為net start mysql

測試代碼

publicstaticvoidmain(String args[]) {

 JDBCOperation.getAll();

 JDBCOperation.insert(newStudent("Achilles","Male","14"));

 JDBCOperation.getAll();

 JDBCOperation.update(newStudent("Bean","","7"));

 JDBCOperation.delete("Achilles");

 JDBCOperation.getAll();

}

Eclipse中的輸出

============================

1 Ender  male 8

2 Bean  male 6

3 Petra  fema 9

4 Peter  male 9

5 _Graff  male 40

6 GOD  fema 255

============================

============================

1 Ender  male 8

2 Bean  male 6

3 Petra  fema 9

4 Peter  male 9

5 _Graff  male 40

6 GOD  fema 255

7 Achilles Male 14

============================

resutl: 1

resutl: 1

============================

1 Ender  male 8

2 Bean  male 7

3 Petra  fema 9

4 Peter  male 9

5 _Graff  male 40

6 GOD  fema 255

============================

五、代碼分析

在上述對數據庫進行增刪改查的過程中,可以發現其共性部分,即通用的流程:

(1)創建Connection對象、SQL查詢命令字符串;

(2)對Connection對象傳入SQL查詢命令,獲得PreparedStatement對象;

(3)對PreparedStatement對象執行executeUpdate()或executeQurey()獲得結果;

(4)先後關閉PreparedStatement對象和Connection對象。

可見,使用JDBC時,最常打交道的是Connection、PreparedStatement這兩個類,以及select中的ResultSet類。

Connection

java.sql

接口 Connection

所有超級接口:Wrapper

--------------------------------------------------------------------------------

public interface Connectionextends Wrapper

與特定數據庫的連接(會話)。在連接上下文中執行 SQL 語句並返回結果。

Connection 對象的數據庫能夠提供描述其表、所支持的 SQL 語法、存儲過程、此連接功能等等的信息。此信息是使用 getMetaData 方法獲得的。

PreparedStatemnt

java.sql

接口 PreparedStatement

所有超級接口:Statement, Wrapper所有已知子接口:CallableStatement

--------------------------------------------------------------------------------

public interface PreparedStatementextends Statement

表示預編譯的 SQL 語句的對象。

SQL 語句被預編譯並存儲在 PreparedStatement 對象中。然後可以使用此對象多次高效地執行該語句。

常用方法

booleanexecute()

在此 PreparedStatement 對象中執行 SQL 語句,該語句可以是任何種類的 SQL 語句。

ResultSet executeQuery()

在此 PreparedStatement 對象中執行 SQL 查詢,並返回該查詢生成的 ResultSet 對象。

intexecuteUpdate()

在此 PreparedStatement 對象中執行 SQL 語句,該語句必須是一個 SQL 數據操作語言(Data  Manipulation Language,DML)語句,比如 INSERT、UPDATE 或 DELETE 語句;或者是無返回內容的 SQL  語句,比如 DDL 語句。

ResultSet

java.sql

接口 ResultSet

所有超級接口:Wrapper所有已知子接口:CachedRowSet, FilteredRowSet, JdbcRowSet, JoinRowSet,RowSet,SyncResolver, WebRowSet

--------------------------------------------------------------------------------

public interface ResultSetextends Wrapper

表示數據庫結果集的數據表,通常通過執行查詢數據庫的語句生成。  

六、思考問題

1.每次SQL操作都需要建立和關閉連接,這勢必會消耗大量的資源開銷,如何避免?

分析:可以采用連接池,對連接進行統一維護,不必每次都建立和關閉。事實上這是很多對JDBC進行封裝的工具所采用的。

2.Java代碼中,傳入的數據格式與數據庫定義不同怎麼辦?如把Java的String對象賦值給數據庫的tinyint屬性。

分析:在執行SQL語句時,數據庫會嘗試進行轉換。根據我的實驗,如果用內容為純字母的String對象傳入tinyint的age屬性時,會被轉化成0。具體轉化規則應該和數據庫有關。

copyright © 萬盛學電腦網 all rights reserved