Hướng dẫn kết nối cơ sở dữ liệu trong java

Question

JDBC 06. Sử dụng JDBC để thêm, xóa, cập nhật dữ liệu bằng câu lệnh INSERT, UPDATE, DELETE

Nội dung chính Show

2. JDBC là gì?
3. Java kết nối với database dựa trên nguyên tắc nào?
4. Download một số các driver quan trọng
5. Tạo project để bắt đầu ví dụ với JDBC
6. Connection
7. Sử dụng JDBC API truy vấn dữ liệu
8. Các kiểu ResultSet
9. Ví dụ Insert dữ liệu
10. PreparedStatement
11. CallableStatement
12. Điều khiển giao dịch (Transaction)

5

JDBC 07. Sử dụng JDBC để truy vấn cơ sở dữ liệu với câu lệnh SELECT

6

JDBC 08. Nên sử dụng PreparedStatement thay thế cho Statement khi dùng JDBC để tương tác CSDL

Tài liệu hướng dẫn này sẽ hướng dẫn các sử dụng Java kết nối vào database. Database được sử dụng làm mẫu trong tài liệu này là "simplehr". Bạn có thể xem các script tạo database tại:

2. JDBC là gì?

JDBC (Java Database Connectivity) là một API tiêu chuẩn dùng để tương tác với các loại cơ sở dữ liệu quan hệ. JDBC có một tập hợp các class và các Interface dùng cho ứng dụng Java có thể nói chuyện với các cơ sở dữ liệu.

Các thành phần của JDBC Api về cơ bản bao gồm:

DriverManager:
- Là một class, nó dùng để quản lý danh sách các Driver (database drivers).
Driver:
- Là một Interface, nó dùng để liên kết các liên lạc với cơ sở dữ liệu, điều khiển các liên lạc với database. Một khi Driver được tải lên, lập trình viên không cần phải gọi nó một cách cụ thể.
Connection :
- Là một Interface với tất cả các method cho việc liên lạc với database. Nó mô tả nội dung liên lạc. tất cả các thông tin liên lạc với cơ sở dữ liệu là thông qua chỉ có đối tượng Connection.
Statement :
- Là một Interface, gói gọn một câu lệnh SQL gửi tới cơ sở dữ liệu được phân tích, tổng hợp, lập kế hoạch và thực hiện.
ResultSet:
- ResultSet đại diện cho tập hợp các bản ghi lấy do thực hiện truy vấn.

3. Java kết nối với database dựa trên nguyên tắc nào?

Java sử dụng JDBC để làm việc với các cơ sở dữ liệu.

Ví dụ bạn làm việc với cơ sở dữ liệu Oracle từ Java bạn cần phải có Driver (Đó là class điều khiển việc kết nối với loại cơ sở dữ liệu bạn muốn). Trong JDBC API chúng ta có java.sql.Driver, nó chỉ là một interface, và nó có sẵn trong JDK. Như vậy bạn phải download thư viện Driver ứng với loại Database mà bạn mong muốn.

Chẳng hạn với Oracle thì class thi hành Interface java.sql.Driver đó là: oracle.jdbc.driver.OracleDriver

java.sql.DriverManager là một class trong JDBC API. Nó làm nhiệm vụ quản lý các Driver.

Bạn hãy xem hình minh họa dưới đây:

Chúng ta có 2 cách để làm việc với một loại cơ sở dữ liệu cụ thể nào đó.

Cách 1: Bạn hãy cung cấp thư viện Driver điều khiển loại cơ sở dữ liệu đó, đây là cách trực tiếp. Nếu bạn dùng DB oracle (hoặc DB khác) bạn phải download thư viện dành cho loại DB này.
Cách 2: Khai báo một "ODBC DataSource", và sử dụng cầu nối JDBC-ODBC để kết nối với "ODBC DataSource" kia. Cầu nối JDBC-ODBC là thứ có sẵn trong JDBC API.

Câu hỏi của chúng ta là "ODBC DataSource" là cái gì?

ODBC - Open Database Connectivity: Nó chính là một bộ thư viện mở, có khả năng kết nối với hầu hết các loại cơ sở dữ liệu khác nhau, và nó miễn phí. Được cung cấp bởi Microsoft.

ODBC DataSource: Trên hệ điều hành Window bạn có thể khai báo một kết nối ODBC tới một loại DB nào đó. Và như vậy chúng ta có một nguồn dữ liệu (Data Source).

Trong JDBC API, đã xây dựng sẵn một cầu nối JDBC-ODBC để JDBC có thể nói chuyện được với ODBC Data Source.

Về tốc độ, cách 1 sẽ nhanh hơn cách 2, vì cách 2 phải sử dụng tới cầu nối.

4. Download một số các driver quan trọng

Trong trường hợp nếu bạn không muốn sử dụng JDBC-ODBC, bạn có thể sử dụng cách trực tiếp kết nối vào Database, trong trường hợp đó cần phải download Driver ứng với mỗi loại DB này. Tại đây tôi hướng dẫn download một loại Driver cho các Database thông dụng:

Oracle
MySQL
SQLServer
....

Bạn có thể xem hướng dẫn tại:

Kết quả chúng ta có một vài file:

mysql-connector-java-x.jar

5. Tạo project để bắt đầu ví dụ với JDBC

Tạo mới project JavaJdbcTutorial:

Tạo thư mục libs trên project và copy các thư viện kết nối trực tiếp các loại database Oracle, MySQL, SQLServer mà bạn vừa download được ở trên vào. Bạn có thể copy hết hoặc một trong các thư viện đó, theo loại DB mà bạn sử dụng.

Chú ý: Bạn chỉ cần download một Driver ứng với loại Database mà bạn quen thuộc. Cơ sở dữ liệu dùng làm ví dụ trong tài liệu này bạn có thể lấy tại:

Nhấn phải vào Project chọn Properties:

Giờ thì bạn có thể sẵn sàng làm việc với một trong các Database (Oracle, MySQL, SQL Server)

6. Connection

Trong tài liệu hướng dẫn này tôi sẽ hướng dẫn các kết nối vào cả 3 loại database:

MySQL
SQLServer
Oracle

Trong khi thực hành, bạn chỉ cần làm việc với một loại DB nào mà bạn quen thuộc.

Chúng ta tạo class ConnectionUtils để lấy ra đối tượng Connection kết nối với Database.

ConnectionUtils.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.SQLException;
public class ConnectionUtils {
  public static Connection getMyConnection() throws SQLException,
          ClassNotFoundException {
      // Sử dụng Oracle.
      // Bạn có thể thay thế bởi Database nào đó.
      return OracleConnUtils.getOracleConnection();
  }
  //
  // Test Connection ...
  //
  public static void main(String[] args) throws SQLException,
          ClassNotFoundException {
      System.out.println("Get connection ... ");
      // Lấy ra đối tượng Connection kết nối vào database.
      Connection conn = ConnectionUtils.getMyConnection();
      System.out.println("Get connection " + conn);
      System.out.println("Done!");
  }
}

OracleConnUtils.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

MySQLConnUtils.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class MySQLConnUtils {
 // Kết nối vào MySQL.
 public static Connection getMySQLConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String dbName = "simplehr";
     String userName = "root";
     String password = "1234";
     return getMySQLConnection(hostName, dbName, userName, password);
 }
 public static Connection getMySQLConnection(String hostName, String dbName,
         String userName, String password) throws SQLException,
         ClassNotFoundException {
     // Khai báo class Driver cho DB MySQL
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("com.mysql.jdbc.Driver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:mysql://localhost:3306/simplehr
     String connectionURL = "jdbc:mysql://" + hostName + ":3306/" + dbName;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

SQLServerConnUtils_JTDS.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class SQLServerConnUtils_JTDS {
 // Kết nối vào SQLServer.
 // (Sử dụng thư viện điều khiển JTDS)
 public static Connection getSQLServerConnection()
         throws SQLException, ClassNotFoundException {
     String hostName = "localhost";
     String sqlInstanceName = "SQLEXPRESS";
     String database = "simplehr";
     String userName = "sa";
     String password = "1234";
     return getSQLServerConnection(hostName, sqlInstanceName, database,
             userName, password);
 }
 // Trường hợp sử dụng SQLServer.
 // Và thư viện JTDS.
 public static Connection getSQLServerConnection(String hostName,
         String sqlInstanceName, String database, String userName,
         String password) throws ClassNotFoundException, SQLException {
     // Khai báo class Driver cho DB SQLServer
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("net.sourceforge.jtds.jdbc.Driver");
     // Cấu trúc URL Connection dành cho SQLServer
     // Ví dụ:
     // jdbc:jtds:sqlserver://localhost:1433/simplehr;instance=SQLEXPRESS
     String connectionURL = "jdbc:jtds:sqlserver://" + hostName + ":1433/"
database + ";instance=" + sqlInstanceName;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}
`

SQLServerConnUtils\_SQLJDBC.java

package org.o7planning.tutorial.jdbc; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class SQLServerConnUtils_SQLJDBC { // Kết nối vào SQLServer. // (Sử dụng thư viện điều khiển SQLJDBC) public static Connection getSQLServerConnection()

     throws SQLException, ClassNotFoundException {
 String hostName = "localhost";
 String sqlInstanceName = "SQLEXPRESS";
 String database = "simplehr";
 String userName = "sa";
 String password = "1234";
 return getSQLServerConnection(hostName, sqlInstanceName,
         database, userName, password);

} // Trường hợp sử dụng SQLServer. // Và thư viện SQLJDBC. public static Connection getSQLServerConnection(String hostName,

     String sqlInstanceName, String database, String userName,
     String password) throws ClassNotFoundException, SQLException {
 // Khai báo class Driver cho DB SQLServer
 // Việc này cần thiết với Java 5
 // Java6 tự động tìm kiếm Driver thích hợp.
 // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
 Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
 // Cấu trúc URL Connection dành cho SQLServer
 // Ví dụ:
 // jdbc:sqlserver://ServerIp:1433/SQLEXPRESS;databaseName=simplehr
 String connectionURL = "jdbc:sqlserver://" + hostName + ":1433"

";instance=" + sqlInstanceName + ";databaseName=" + database;

 Connection conn = DriverManager.getConnection(connectionURL, userName,
         password);
 return conn;

}

`

ODBCConnUtils.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class ODBCConnUtils {
  // Lấy ra kết nối vào ODBC Data Source có tên "simplehr-ds".
  public static Connection getJdbcOdbcConnection() throws SQLException,
          ClassNotFoundException {
      String odbcDataSourceName = "simplehr-ds";
      String userName = "simplehr";
      String password = "simplehr";
      return getJdbcOdbcConnection(odbcDataSourceName, userName, password);
  }
  public static Connection getJdbcOdbcConnection(String odbcDataSourceName,
          String userName, String password) throws SQLException,
          ClassNotFoundException {
      // Khai báo class Driver (Cầu nối Jdbc-Odbc)
      // Việc này cần thiết với Java 5
      // Java6 tự động tìm kiếm Driver thích hợp.
      // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
      Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
      // Cấu trúc URL Connection dành cho JDBC-ODBC
      String connectionURL = "jdbc:odbc:" + odbcDataSourceName;
      Connection conn = DriverManager.getConnection(connectionURL, userName,
              password);
      return conn;
  }
}

Bạn có thể thay đổi Class ConnectionUtils để sử dụng kết nối tới một Database nào đó quen thuộc. Và chạy class này để test kết nối.

Get connection ...
Get connection oracle.jdbc.driver.T4CConnection@5f54e92c
Done!

Chú ý: Nếu bạn sử dụng MySQL hoặc SQL Server mặc định 2 Database này chặn không cho phép kết nối vào nó từ một IP khác. Bạn cần cấu hình để cho phép điều này. Bạn có thể xem hướng dẫn trong tài liệu cài đặt và cấu hình MySQL, SQL Server trên o7planning.
Cài đặt và cấu hình MySQL Community:
Cài đặt và cấu hình SQL Server:

7. Sử dụng JDBC API truy vấn dữ liệu

Đây là hình ảnh dữ liệu trong bảng Employee. Chúng ta sẽ xem cách Java lấy ra dữ liệu thế nào thông qua một ví dụ:

ResultSet là một đối tượng Java, nó được trả về khi bạn truy vấn (query) dữ liệu. Sử dụng ResultSet.next() để di chuyển con trỏ tới các bản ghi tiếp theo (Di chuyển dòng). Tại một bản ghi nào đó bạn sử dụng các method ResultSet.getXxx() để lấy ra các giá trị tại các cột. Các cột được đánh với thứ tự 1,2,3,...

** ResultSet **

public String getString(int columnIndex) throws SQLException;
public boolean getBoolean(int columnIndex) throws SQLException;
public int getInt(int columnIndex) throws SQLException;
public double getDouble(int columnIndex) throws SQLException;
...
public String getString(String columnLabel) throws SQLException;
public boolean getBoolean(String columnLabel) throws SQLException;
public int getInt(String columnLabel) throws SQLException;
public double getDouble(String columnLabel) throws SQLException;
....

Ví dụ minh họa:

QueryDataExample.java

package org.o7planning.tutorial.jdbc.basic;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import org.o7planning.tutorial.jdbc.ConnectionUtils;
public class QueryDataExample {
  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {
      // Lấy ra đối tượng Connection kết nối vào DB.
      Connection connection = ConnectionUtils.getMyConnection();
      // Tạo đối tượng Statement.
      Statement statement = connection.createStatement();
      String sql = "Select Emp_Id, Emp_No, Emp_Name from Employee";
      // Thực thi câu lệnh SQL trả về đối tượng ResultSet.
      ResultSet rs = statement.executeQuery(sql);
      // Duyệt trên kết quả trả về.
      while (rs.next()) {// Di chuyển con trỏ xuống bản ghi kế tiếp.
          int empId = rs.getInt(1);
          String empNo = rs.getString(2);
          String empName = rs.getString("Emp_Name");
          System.out.println("--------------------");
          System.out.println("EmpId:" + empId);
          System.out.println("EmpNo:" + empNo);
          System.out.println("EmpName:" + empName);
      }
      // Đóng kết nối
      connection.close();
  }
}

Kết quả chạy ví dụ:

EmpId:7900
EmpNo:E7900
EmpName:ADAMS

EmpId:7934
EmpNo:E7934
EmpName:MILLER

8. Các kiểu ResultSet

Bạn đã làm quen với ResultSet với các ví dụ phía trên. Mặc định các ResultSet khi duyệt dữ liệu chỉ có thể chạy từ trên xuống dưới, từ trái sang phải. Điều đó có nghĩa là với các ResultSet mặc định bạn không thể gọi:

ResultSet.previous() : Lùi lại một bản ghi.
Trên cùng một bản ghi không thể gọi ResultSet.getXxx(4) rồi mới gọi ResultSet.getXxx(2).

Việc cố tình gọi sẽ bị một Exception.

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

0

resultSetType

Ý nghĩa

TYPE_FORWARD_ONLY

- ResultSet chỉ cho phép duyệt từ trên xuống dưới, từ trái sang phải. Đây là kiểu mặc định của các ResultSet.

TYPE_SCROLL_INSENSITIVE

- ResultSet cho phép cuộn tiến lùi, sang trái, sang phải, nhưng không nhạy với các sự thay đổi dữ liệu dưới DB. Nghĩa là trong quá trình duyệt qua một bản ghi và lúc nào đó duyệt lại bản ghi đó, nó không lấy các dữ liệu mới nhất của bản ghi mà có thể bị ai đó thay đổi.

TYPE_SCROLL_SENSITIVE

- ResultSet cho phép cuộn tiến lùi, sang trái, sang phải, và nhạy cảm với sự thay đổi dữ liệu.

resultSetConcurrency

Ý nghĩa

CONCUR_READ_ONLY

- Khi duyệt dữ liệu với các ResultSet kiểu này bạn chỉ có thể đọc dữ liệu.

CONCUR_UPDATABLE

- Khi duyệt dữ liệu với các ResultSet kiểu này bạn chỉ có thể thay đổi dữ liệu tại nơi con trỏ đứng, ví dụ update giá trị cột nào đó.

ScrollableResultSetExample.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

1

Kết quả chạy ví dụ:

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

2

9. Ví dụ Insert dữ liệu

InsertDataExample.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

3

Kết quả chạy ví dụ:

10. PreparedStatement

PreparedStatement là một Interface con của Statement.

PreparedStatement sử dụng để chuẩn bị trước các câu lệnh SQL, và tái sử dụng nhiều lần, giúp cho chương trình thực hiện nhanh hơn.

PrepareStatementExample.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

4

Kết quả chạy ví dụ:

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

5

11. CallableStatement

CallableStatement được xây dựng để gọi một thủ tục (procedure) hoặc hàm (function) của SQL.

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

6

Để làm ví dụ với CallableStatement chúng ta cần một hàm hoặc một thủ tục trong DB. Với Oracle, MySQL hoặc SQLServer bạn có thể tạo nhanh một thủ tục như dưới đây:

ORACLE

Get_Employee_Info

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

7

MySQL

Get_Employee_Info

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

8

SQL Server

Get_Employee_Info

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class OracleConnUtils {
 // Kết nối vào ORACLE.
 public static Connection getOracleConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String sid = "db11g";
     String userName = "simplehr";
     String password = "simplehr";
     return getOracleConnection(hostName, sid, userName, password);
 }
 public static Connection getOracleConnection(String hostName, String sid,
         String userName, String password) throws ClassNotFoundException,
         SQLException {
     // Khai báo class Driver cho DB Oracle
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("oracle.jdbc.driver.OracleDriver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:oracle:thin:@localhost:1521:db11g
     String connectionURL = "jdbc:oracle:thin:@" + hostName + ":1521:" + sid;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

9

CallableStatementExample.java

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class MySQLConnUtils {
 // Kết nối vào MySQL.
 public static Connection getMySQLConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String dbName = "simplehr";
     String userName = "root";
     String password = "1234";
     return getMySQLConnection(hostName, dbName, userName, password);
 }
 public static Connection getMySQLConnection(String hostName, String dbName,
         String userName, String password) throws SQLException,
         ClassNotFoundException {
     // Khai báo class Driver cho DB MySQL
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("com.mysql.jdbc.Driver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:mysql://localhost:3306/simplehr
     String connectionURL = "jdbc:mysql://" + hostName + ":3306/" + dbName;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

0

Kết quả chạy ví dụ:

package org.o7planning.tutorial.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class MySQLConnUtils {
 // Kết nối vào MySQL.
 public static Connection getMySQLConnection() throws SQLException,
         ClassNotFoundException {
     String hostName = "localhost";
     String dbName = "simplehr";
     String userName = "root";
     String password = "1234";
     return getMySQLConnection(hostName, dbName, userName, password);
 }
 public static Connection getMySQLConnection(String hostName, String dbName,
         String userName, String password) throws SQLException,
         ClassNotFoundException {
     // Khai báo class Driver cho DB MySQL
     // Việc này cần thiết với Java 5
     // Java6 tự động tìm kiếm Driver thích hợp.
     // Nếu bạn dùng Java6, thì ko cần dòng này cũng được.
     Class.forName("com.mysql.jdbc.Driver");
     // Cấu trúc URL Connection dành cho Oracle
     // Ví dụ: jdbc:mysql://localhost:3306/simplehr
     String connectionURL = "jdbc:mysql://" + hostName + ":3306/" + dbName;
     Connection conn = DriverManager.getConnection(connectionURL, userName,
             password);
     return conn;
 }
}

1

12. Điều khiển giao dịch (Transaction)

Giao dịch (Transaction) là một khái niệm quan trọng trong SQL.

Ví dụ người A chuyển một khoản tiền 1000$ vào tài khoản người B như vậy trong Database diễn ra 2 quá trình:

Trừ số dư tài khoản của người A đi 1000$
Thêm vào số dư tài khoản của người B 1000$.

Và giao dịch được gọi là thành công nếu cả 2 bước kia thành công. Ngược lại chỉ cần 1 trong hai bước hỏng là coi như giao dịch không thành công, phải rollback lại trạng thái ban đầu.

hướng dẫn Mẹo Hay JDBC trong Java