寫在前面：JDBC是sun公司（已被Oracle收購）制定一系列介面標準，由不同廠商（Oracle、MySQL等）實現介面方法並封裝成驅動檔案，供開發人員操作資料庫。也就是說，開發人員可採用統一的程式碼

一、三個重要物件：

   a.Connection

  代表著Java程式與資料庫建立的連線。

   b.Statement

  代表SQL傳送器，用於傳送和執行SQL語句。

   c.ResultSet

  代表封裝的資料庫返回的結果集，用於獲取查詢結果。

二、程式設計步驟：

         1、載入驅動（需要事先將驅動程式對應的jar檔案放到classpath對應的路徑）

         驅動：就是不同的資料庫廠商實現的API。Class.forName(驅動類名);

         2、獲得連線。Connection conn = DriverManager.getConnection(url,user,pwd);

         3、獲得Statement。Statment stat = conn.creatStatement();

         4、執行SQL。

                   a.執行查詢：ResultSet rst = stat.executeQuery(SQL);

                   b.執行刪除、更新、插入：int = stat.executeUpdate(SQL);

         5、如果是查詢，需要遍歷ResultSet

                   遍歷：將查詢的結果一條條取出來，獲取其中的資料

         6、關閉連線

三、示例：

mysql簡單使用：

（1）登入MySQL（使用root使用者）：mysql -uroot;

（2）檢視資料庫：show databases;

（3）建立資料庫（設定預設字符集utf-8）：create database test1 default character set utf8;

（4）使用某個資料庫：use test1;

（5）檢視當前資料庫有哪些表：show tables;

（6）建表：

         create table t_user(

                   id int primary key auto_increment,

                   username varchar(50),

                   pwd varchar(30),

                   age int

         )type=innodb;

         insert into t_user(username,pwd,age)values('jetty','test',23);

         注意：

         auto_increment：自增長列，該列由資料庫自動賦值，一般用於主鍵生成

程式訪問：

public class TestJdbc {

	static String driver = "com.mysql.jdbc.Driver";
	static String url = "jdbc:mysql://localhost:3306/test1";
	static String dbUser = "root";
	static String dbPwd = "111111";

	public static void main(String[] args) throws Exception {
		// findUsers1("jetty", "test");
		findUsers1("sadfas", "1' or '1'='1");//錯誤驗證依然可以獲取使用者資訊，出現SQL注入
		findUsers2("tom", "tompwd");
	}

	/**
	 * 使用原始Statement（容易出現SQL注入）
	 * 
	 * @param username
	 * @param pwd
	 * @throws Exception
	 */
	public static void findUsers1(String username, String pwd) throws Exception {
		// 1.載入類
		Class.forName(driver);
		// 2.獲取連線
		Connection conn = DriverManager.getConnection(url, dbUser, dbPwd);
		System.out.println(conn);
		// 3.獲得Statement
		Statement state = conn.createStatement();
		// 4.呼叫Statement的方法執行SQL
		String sql = "select * from t_user where username = " + "'" + username
				+ "'" + " and pwd = '" + pwd + "'";
		// 5.execute()將SQL語句傳送給資料庫，資料庫執行查詢，資料庫執行相應查詢，查詢的結果會封裝到ResultSet物件。
		ResultSet rst = state.executeQuery(sql);
		// 可以將ResultSet看成一張表，next()含義是，將指標向下移動一位，如果返回值為true，表示當前有記錄可以讀取
		while (rst.next()) {
			int id = rst.getInt("id");
			String name = rst.getString("username");
			String realPwd = rst.getString("pwd");
			int age = rst.getInt("age");
			System.out.println("id:" + id + ",username:" + name + ",realPwd:"
					+ realPwd + ",age:" + age);
		}
		// 6.關閉資源，一般只需關閉連線即可
		if (rst != null) {
			rst.close();
		}
		if (state != null) {
			state.close();
		}
		if (conn != null) {
			conn.close();
		}
	}

	/**
	 * 使用PreparedStatement
	 * 
	 * @param username
	 * @param pwd
	 * @throws Exception
	 */
	public static void findUsers2(String username, String pwd) throws Exception {
		Class.forName(driver);
		Connection conn = DriverManager.getConnection(url, dbUser, dbPwd);
		// sql表示一個佔位符
		String sql = "select * from t_user where username=? and pwd=?";
		PreparedStatement prep = conn.prepareStatement(sql);
		prep.setString(1, username);
		prep.setString(2, pwd);
		ResultSet rst = prep.executeQuery();
		while (rst.next()) {
			int id = rst.getInt("id");
			int age = rst.getInt("age");
			System.out.println("id:" + id + ",age:" + age);
		}
		// 6.關閉資源，一般只需關閉連線即可
		if (rst != null) {
			rst.close();
		}
		if (prep != null) {
			prep.close();
		}
		if (conn != null) {
			conn.close();
		}
	}

}

[email protected]
id:1,username:jetty,realPwd:test,age:23
id:2,username:tom,realPwd:tompwd,age:26
id:2,age:26

四、Statement和PreparedStatement

PrepareStatement和Statement區別和聯絡
--PrepareStatement從Statement繼承
--都是用於傳送和執行SQL語句的
--PrepareStatement是一種預編譯的Statement物件。
  Statement物件是在executeUpdate或executeQuery方法時指定sql,此時將sql語句傳送和執行。
  PrepareStatement物件是在建立時指定併發送sql，在executeUpdate或executeQuery方法時觸發sql執行。

使用原有Statement有以下問題：
--容易遭受注入式攻擊
--拼寫SQL繁瑣和麻煩
通過PrepareStatement可以解決上述問題

PrepareStatement使用步驟：
--編寫帶?號的sql
--利用con.prepareStatement(sql);方法獲取PrepareStatement物件
--利用setXXX()方法給sql的?設定引數值
--呼叫無參的executeUpdate()或executeQuery()執行sql.

圖示：

總結：如圖所示，PrepareStatement是一個預編譯的Statement，將帶佔位符？的SQL語句傳送給資料庫後，SQL語句不會立即執行，資料庫會生成一個執行計劃，此時SQL語句結構已確定，不可更改注入，然後利用setXXX()方法給sql的?設定引數值，傳參後即執行計劃，返回結果集。另外，由於執行計劃已生成，只要傳入引數就可執行計劃，這在大批量存入資料時，編碼更簡單，效率更高。

五、JDBC批處理的使用

 用於處理批量的增刪改操作。可一次向資料庫端傳送多條SQL命令,資料庫可以對這些SQL命令批量編譯執行。
從而提升了批量操作的效能。
  1）Statement
   Statement stat = ...;
   //將sql放入當前的SQL批次中
   stat.addBatch(sql);
   stat.addBatch(sql1);
   ....
   //傳送和執行batch中的SQL
   stat.executeBatch();
  *2)PrepareStatement
   //傳送指定sql語句給資料庫
   //資料庫進行預編譯
   PrepareStatement pst = ...;
  pst.setxxx();//設定?引數值
   //將當前一組引數放入batch快取
  pst.addBatch();
  pst.setxxx();
  pst.addBatch();//將引數放入batch
  //執行批處理
  pst.executeBatch();

  提示：batch中存放的sql語句或運算元不要太多,需要根據機器效能決定，一般採用20個即可。

  示例：

public void saveUsers(List<User> users) throws Exception {
		try {
			conn = DBUtil.getConnection();
			stat = conn
					.prepareStatement("insert into t_user(username,pwd,age)values(?,?,?)");
			for (int i = 0; i < users.size(); i++) {
				User user = users.get(i);
				stat.setString(1, user.getUsername());
				stat.setString(2, user.getPwd());
				stat.setInt(3, user.getAge());
				// stat.executeUpdate();
				stat.addBatch();// 引數先不傳送，先儲存下來
			}
			stat.executeBatch();// 一次性發送所有儲存的引數到資料庫執行
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			DBUtil.close(conn);
		}
}

addBatch():新增一條要執行的sql。

executeBatch():執行之前新增的所有sql。

clearBatch():清空之前快取過的sql內容。（可不寫，會自動清空）

轉載請註明出處：http://blog.csdn.net/daijin888888/article/details/50965232