Hướng dẫn sử dụng Java JDBC kết nối cơ sở dữ liệu

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!");
  }

}

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;
 }
}

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;
 }
}

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;
 }

}

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;
 }

}

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;
  }
}

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;

....

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();
  }

}

public  Statement createStatement(int resultSetType, int resultSetConcurrency)
       throws SQLException;

// Ví dụ:
Statement statement = connection.createStatement(
               ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

// ResultSet có thể cuộn (tiến lùi, sang trái sang phải).
ResultSet rs = statement.executeQuery(sql);

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 ScrollableResultSetExample {

  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {

      // Lấy ra đối tượng Connection kết nối tới DB.
      Connection connection = ConnectionUtils.getMyConnection();

      // Tạo một đối tượng Statement
      // Có thể cuộn dữ liệu, nhưng không nhậy với các thay đổi dưới DB.
      // Con trỏ chỉ có khả năng đọc, không có khả năng update dữ liệu trong quá trình duyệt.
      Statement statement = connection.createStatement(
              ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);

      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);

     
      // Nhẩy con trỏ tới cuối
      boolean last = rs.last();
     
      System.out.println("last : "+ last);
     
     
      if(last) {
          // Ghi ra thông tin bản ghi cuối.
          System.out.println("EmpId:" + rs.getInt(1));
          System.out.println("EmpNo:" + rs.getString(2));
          System.out.println("EmpName:" + rs.getString(3));
      }
     
     
      System.out.println("--------------------");
     
      // Nhẩy con trỏ lùi lại lần 1
      boolean previous =rs.previous();
      System.out.println("Previous 1: "+ previous);
     
      // Nhẩy lùi con trỏ lần 2
      previous =rs.previous();
      System.out.println("Previous 2: "+ previous);    
 
     
      // Duyệt trên kết quả trả về.
      while (rs.next()) {
          // Lấy dữ liệu cột 2
          String empNo = rs.getString(2);
          // Rồi mới lấy dữ liệu cột 1.
          int empId = rs.getInt(1);
         
          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();
  }

}

package org.o7planning.tutorial.jdbc.basic;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import org.o7planning.tutorial.jdbc.ConnectionUtils;

public class InsertDataExample {

  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {

      // Lấy ra kết nối tới cơ sở dữ liệu.
      Connection connection = ConnectionUtils.getMyConnection();

      Statement statement = connection.createStatement();

      String sql = "Insert into Salary_Grade (Grade, High_Salary, Low_Salary) "
              + " values (2, 20000, 10000) ";

      // Thực thi câu lệnh.
      // executeUpdate(String) sử dụng cho các loại lệnh Insert,Update,Delete.
      int rowCount = statement.executeUpdate(sql);

      // In ra số dòng được trèn vào bởi câu lệnh trên.
      System.out.println("Row Count affected = " + rowCount);

  }
}

package org.o7planning.tutorial.jdbc.pareparedstatement;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.o7planning.tutorial.jdbc.ConnectionUtils;

public class PrepareStatementExample {

  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {
      // Lấy ra kết nối tới cơ sở dữ liệu.
      Connection connection = ConnectionUtils.getMyConnection();

      // Tạo một câu SQL có 2 tham số (?)
      String sql = "Select emp.Emp_Id, emp.Emp_No, emp.Emp_Name, emp.Dept_Id from Employee emp "
              + " where emp.Emp_Name like ? and emp.Dept_Id = ? ";

      // Tạo một đối tượng PreparedStatement.
      PreparedStatement pstm = connection.prepareStatement(sql);

      // Sét đặt giá trị tham số thứ nhất (Dấu ? thứ nhất)        
      pstm.setString(1, "%S");
      // Sét đặt giá trị tham số thứ hai (Dấu ? thứ hai)
      pstm.setInt(2, 20);

      ResultSet rs = pstm.executeQuery();

      while (rs.next()) {
          System.out.println(" ---- ");
          System.out.println("EmpId : " + rs.getInt("Emp_Id"));
          System.out.println("EmpNo : " + rs.getString(2));
          System.out.println("EmpName : " + rs.getString("Emp_Name"));
      }
     
      System.out.println();
      System.out.println("Set other parameters ..");
     
      // Tái sử dụng PreparedStatement.
      // Sét đặt các tham số khác.
      pstm.setString(1, "KI%");
      pstm.setInt(2,10);
     
      // Thực thi câu lệnh truy vấn.
      rs = pstm.executeQuery();
     
      while (rs.next()) {
          System.out.println(" ---- ");
          System.out.println("EmpId : " + rs.getInt("Emp_Id"));
          System.out.println("EmpNo : " + rs.getString(2));
          System.out.println("EmpName : " + rs.getString("Emp_Name"));
      }
  }
}

// Câu lệnh gọi thủ tục SQL trên Java
String sql = "{call procedure_name(?,?,?)}";

// Câu lệnh gọi một hàm SQL trên Java
String sql ="{? = call function_name(?,?,?)}";

-- Thủ tục lấy ra thông tin của một nhân viên,
-- Truyền vào tham số p_Emp_ID  (Integer)
-- Có 4 tham số đầu ra v_Emp_No, v_First_Name, v_Last_Name, v_Hire_Date

Create Or Replace Procedure Get_Employee_Info(p_Emp_Id     Integer
                                            ,v_Emp_No     Out Varchar2
                                            ,v_First_Name Out Varchar2
                                            ,v_Last_Name  Out Varchar2
                                            ,v_Hire_Date  Out Date) Is
Begin
  v_Emp_No := 'E' || p_Emp_Id;
  --
  v_First_Name := 'Michael';
  v_Last_Name  := 'Smith';
  v_Hire_Date  := Sysdate;
End Get_Employee_Info;

-- Thủ tục lấy ra thông tin của một nhân viên,
-- Truyền vào tham số p_Emp_ID  (Integer)
-- Có 4 tham số đầu ra v_Emp_No, v_First_Name, v_Last_Name, v_Hire_Date

CREATE PROCEDURE get_Employee_Info(p_Emp_ID     Integer,
                                    out       v_Emp_No        Varchar(50) ,
                                    out       v_First_Name    Varchar(50) ,
                                    Out       v_Last_name    Varchar(50) ,
                                    Out       v_Hire_date      Date)
BEGIN
  set v_Emp_No  = concat( 'E' , Cast(p_Emp_Id as char(15)) );
--
  set v_First_Name = 'Michael';
  set v_Last_Name  = 'Smith';
  set v_Hire_date  = curdate();
END

-- Thủ tục lấy ra thông tin của một nhân viên,
-- Truyền vào tham số p_Emp_ID  (Integer)
-- Có 4 tham số đầu ra v_Emp_No, v_First_Name, v_Last_Name, v_Hire_Date

CREATE PROCEDURE Get_Employee_Info
     @p_Emp_Id       Integer ,
     @v_Emp_No      Varchar(50)   OUTPUT,
     @v_First_Name  Varchar(50)   OUTPUT,
     @v_Last_Name  Varchar(50)   OUTPUT,
     @v_Hire_Date    Date             OUTPUT
AS
BEGIN
     set @v_Emp_No  =   'E' + CAST( @p_Emp_Id as varchar)  ;
     --
     set @v_First_Name = 'Michael';
     set @v_Last_Name  = 'Smith';
     set @v_Hire_date  = getdate();
END

package org.o7planning.tutorial.jdbc.callablestatement;

import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.Date;
import java.sql.SQLException;

import org.o7planning.tutorial.jdbc.ConnectionUtils;

public class CallableStatementExample {

  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {
      // Lấy ra kết nối tới cơ sở dữ liệu.
      Connection connection = ConnectionUtils.getMyConnection();

      // Câu lệnh gọi thủ tục (***)
      String sql = "{call get_Employee_Info(?,?,?,?,?)}";

      // Tạo một đối tượng CallableStatement.
      CallableStatement cstm = connection.prepareCall(sql);

      // Truyền tham số vào hàm (p_Emp_ID)
      // (Là dấu chấm hỏi thứ 1 trên câu lệnh sql ***)
      cstm.setInt(1, 10);

      // Đăng ký nhận giá trị trả về tại dấu hỏi thứ 2
      // (v_Emp_No)
      cstm.registerOutParameter(2, java.sql.Types.VARCHAR);        

      // Đăng ký nhận giá trị trả về tại dấu hỏi thứ 3
      // (v_First_Name)
      cstm.registerOutParameter(3, java.sql.Types.VARCHAR);

      // Đăng ký nhận giá trị trả về tại dấu hỏi thứ 4
      // (v_Last_Name)
      cstm.registerOutParameter(4, java.sql.Types.VARCHAR);

      // Đăng ký nhận giá trị trả về tại dấu hỏi thứ 5
      // (v_Hire_Date)
      cstm.registerOutParameter(5, java.sql.Types.DATE);

      // Thực thi câu lệnh
      cstm.executeUpdate();

      String empNo = cstm.getString(2);
      String firstName = cstm.getString(3);
      String lastName = cstm.getString(4);
      Date hireDate = cstm.getDate(5);

      System.out.println("Emp No: " + empNo);
      System.out.println("First Name: " + firstName);
      System.out.println("Last Name: " + lastName);
      System.out.println("Hire Date: " + hireDate);

  }
}

package org.o7planning.tutorial.transaction;

import java.sql.Connection;
import java.sql.SQLException;

import org.o7planning.tutorial.jdbc.ConnectionUtils;

public class TransactionExample {

  private static void doJob1(Connection conn) {
      // Làm gì đó tại đây.
      // Insert update dữ liêu.
  }

  private static void doJob2(Connection conn) {
      // Làm gì đó tại đây.
      // Insert update dữ liêu.
  }

  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {
      // Lấy ra kết nối tới cơ sở dữ liệu.
      Connection connection = ConnectionUtils.getMyConnection();

      // Sét đặt chế độ tự động Commit thành false
      // Để tự quản lý việc commit trên chương trình.
      connection.setAutoCommit(false);

      try {
          // Làm một việc gì đó liên quan tới DB.
          doJob1(connection);
          // Lamf nhiệm vụ thứ 2
          doJob2(connection);

          // Gọi method commit dữ liệu xuống DB.
          connection.commit();

      }
      // Có vấn đề gì đó lỗi xẩy ra.
      catch (Exception e) {
          e.printStackTrace();
          // Rollback dữ liệu
          connection.rollback();
      }

      // Đóng Connection.
      connection.close();
  }

}

package org.o7planning.tutorial.transaction;

import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;

import org.o7planning.tutorial.jdbc.ConnectionUtils;

public class BatchExample {

  public static void main(String[] args) throws SQLException,
          ClassNotFoundException {

      Connection conn = ConnectionUtils.getMyConnection();

      try {
          // Create statement object
          Statement stmt = conn.createStatement();

          // Set auto-commit to false
          conn.setAutoCommit(false);

          // Create SQL statement
          // Tạo câu lệnh Insert dữ liệu vào bảng Employee
          String sql1 = "Update Employee emp set emp.Salary = emp.Salary + 100 "
                  + " where emp.Dept_Id = 10 ";
          // Add above SQL statement in the batch.
          // Thêm câu lệnh SQL trên vào lô
          stmt.addBatch(sql1);

          // Create one more SQL statement
          String sql2 = "Update Employee emp set emp.Salary = emp.Salary + 20 "
                  + " where emp.Dept_Id = 20 ";
          // Add above SQL statement in the batch.
          // Thêm vào lô
          stmt.addBatch(sql2);

          // Create one more SQL statement
          String sql3 = "Update Employee emp set emp.Salary = emp.Salary + 30 "
                  + " where emp.Dept_Id = 30 ";
          // Add above SQL statement in the batch.
          // Thêm vào lô
          stmt.addBatch(sql3);

          // Create an int[] to hold returned values
          int[] counts = stmt.executeBatch();

          System.out.println("Sql1 count = " + counts[0]);
          System.out.println("Sql2 count = " + counts[1]);
          System.out.println("Sql3 count = " + counts[2]);

          // Explicitly commit statements to apply changes
          conn.commit();
      } catch (Exception e) {
          e.printStackTrace();
          conn.rollback();
      }
  }

}

package org.o7planning.tutorial.transaction;

import java.sql.Connection;
import java.sql.Date;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.UUID;

import org.o7planning.tutorial.jdbc.ConnectionUtils;

public class BatchExample2 {

  public static void main(String[] args) throws ClassNotFoundException,
          SQLException {

      Connection conn = ConnectionUtils.getMyConnection();

      try {
          String sql = "Insert into Timekeeper(Timekeeper_Id, Date_Time, In_Out, Emp_Id) "
                  + " values (?,?,?,?) ";
          // Create statement object
          PreparedStatement stmt = conn.prepareStatement(sql);

          // Set auto-commit to false
          conn.setAutoCommit(false);

          // Sét đặt các tham số.
          stmt.setString(1, UUID.randomUUID().toString());
          stmt.setDate(2, new Date(System.currentTimeMillis()));
          stmt.setString(3, "I");
          stmt.setInt(4, 7839);
          // Thêm vào lô.
          stmt.addBatch();

          // Sét đặt các giá trị tham số khác
          stmt.setString(1, UUID.randomUUID().toString());
          stmt.setDate(2, new Date(System.currentTimeMillis()));
          stmt.setString(3, "I");
          stmt.setInt(4, 7566);
          // Thêm vào lô.
          stmt.addBatch();
     

          // Create an int[] to hold returned values
          int[] counts = stmt.executeBatch();

          System.out.println("counts[0] = " + counts[0]);
          System.out.println("counts[1] = " + counts[1]);

          // Explicitly commit statements to apply changes
          conn.commit();
      } catch (Exception e) {
          e.printStackTrace();
          conn.rollback();
      }
  }

}