Trong bài này tôi sẽ hướng dẫn các bạn sử dụng kết nối vào database sử dụng Java JDBC.
Bạn đang xem: Kết nối cơ sở dữ liệu trong java với mysql



JDBC có thể làm việc với bất kỳ cơ sở dữ liệu (MySQL, PostgreSQL, Oracle, SQL Server, …) dựa vào một Driver được cung cấp.
JDBC API bao gồm hai package chính:
java.sql : là một phần của Java standard.javax.sql : là một phần của Java enterprise.Các thành phần của JDBC

Kết nối database với Java JDBC
Để làm việc với JDBC, bạn cần cài đặt Java và một cơ sở dữ liệu (database). Bạn có thể sử dụng bất kỳ database nào, chẳng hạn MySQL.
Như đã giới thiệu ở trên, để làm việc với cơ sở dữ liệu từ Java cần phải có Driver. Trong JDBC API, chúng ta có java.sql.Driver, đây là một interface có sẵn trong JDK. Mỗi hệ quản trị cần cài đặt một Driver riêng tương ứng với cơ sở dữ liệu đó. Như vậy công việc cần phải làm là download thư viện Driver ứng với loại Database mong muốn sử dụng.
Download Driver
Oracle Database JDBC DriverTruy cập vào link: https://www.oracle.com/database/technologies/jdbcdriver-ucp-downloads.html
Chọn phiên bản ojdbc
Nếu sử dụng maven project, các bạn có thể add dependency tương ứng ở link sau: https://mvnrepository.com/artifact/com.oracle.jdbc
dependency> groupId>com.oracle.jdbcgroupId> artifactId>ojdbc14artifactId> version>12.2.0.1version> dependency>MySQL Database JDBC DriverCác bạn thêm maven dependency hoặc download gói jar tương ứng tại đây: https://mvnrepository.com/artifact/mysql/mysql-connector-java
dependency> groupId>mysqlgroupId> artifactId>mysql-connector-javaartifactId> version>8.0.17version> dependency>SQL Server (JTDS) Database JDBC DriverCác bạn thêm maven dependency hoặc download gói jar tương ứng tại đây: https://mvnrepository.com/artifact/net.sourceforge.jtds/jtds
dependency> groupId>net.sourceforge.jtdsgroupId> artifactId>jtdsartifactId> version>1.3.1version> dependency>PostgreSQL Database JDBC DriverCác bạn thêm maven dependency hoặc download gói jar tương ứng tại đây: https://mvnrepository.com/artifact/org.postgresql/postgresql
dependency> groupId>org.postgresqlgroupId> artifactId>postgresqlartifactId> version>42.2.7version> dependency>MariaDB Database JDBC DriverCác bạn thêm maven dependency hoặc download gói jar tương ứng tại đây: https://mvnrepository.com/artifact/org.mariadb.jdbc/mariadb-java-client
dependency> groupId>org.mariadb.jdbcgroupId> artifactId>mariadb-java-clientartifactId> version>2.4.4version> dependency>MongoDB Database JDBC DriverCác bạn thêm maven dependency hoặc download gói jar tương ứng tại đây: https://mvnrepository.com/artifact/org.mongodb/mongo-java-driver
dependency> groupId>org.mongodbgroupId> artifactId>mongo-java-driverartifactId> version>3.11.0version> dependency>
Kết nối database từ Java
Các bước giao tiếp giữa chương trình Java và Database:Load Driver.Tạo kết nối (Open Connection).Tạo câu lệnh truy vấn SQL (Statement).Thực thi câu lệnh truy vấn SQL (Execute Query).Đóng kết nối (Close Connection).Load DriverĐể kết nối với database, chúng ta cần load driver và register nó với ứng dụng. Có 2 cách để thực hiện:
Class.forName() : load class Driver trong memory tại thời điểm runtime. Để đăng ký gọi phương thức: Class.forName(“driverName”);DriverManager.registerDriver() : DriverManager là class có sẵn trong Java. Để đăng ký gọi phương thức: DriverManager.registerDriver(new DriverName());Chẳng hạn để kết nối với MySQL database, ta đăng ký như sau:
Class.forName("com.mysql.jdbc.Driver"); // Or DriverManager.registerDriver(new com.mysql.cj.jdbc.Driver());Tạo kết nối (Open Connection)Sau khi đã load Driver, chúng ta tạo connection:
DriverManager.getConnection(connectionURL); // Or DriverManager.getConnection(connectionURL, userName, password);Ví dụ với MySQL:
// Pattern String connectionURL = "jdbc:mysql://hostname:port/dbname"; // Example String connectionURL = "jdbc:mysql://hostname:3306/jdbcdemo"; Connection con = DriverManager.getConnection(connectionURL, username, password);Tạo câu lệnh truy vấn SQL (Statement)Sau khi một kết nối được thiết lập, chúng ta có thể tương tác với cơ sở dữ liệu.
Các interface JDBCStatement, CallableStatement và PreparedStatement xác định các phương thức cho phép gửi các lệnh SQL và nhận dữ liệu từ cơ sở dữ liệu.
Statement st = con.createStatement();Thực thi câu lệnh truy vấn SQL (Execute Query)Bây giờ đến phần quan trọng nhất, đó là thực hiện câu lệnh truy vấn SQL (execute query). Như chúng ta biết, có thể có nhiều loại truy vấn. Một trong số đó là:
Truy vấn để cập nhật (update) / chèn (insert)/ xóa (delete) trong cơ sở dữ liệu.Truy vấn để lấy dữ liệu (select).Statement cung cấp một số phương thức để thực thi truy vấn SQL tương ứng với các loại trên:
Phương thức execQuery() : được sử dụng để thực hiện các truy vấn truy xuất giá trị từ cơ sở dữ liệu (select). Phương thức này trả về đối tượng ResultSet có thể được sử dụng để lấy tất cả các dữ liệu (record) của bảng.Phương thức execUpdate() : được sử dụng để thực hiện các truy vấn insert/ update/ delete.Phương thức execute() : có thể thực thi cả 2 trường hợp trên. Nếu phương thức statement.getUpdateCount() trả về số lượng record bị affect.Nếu giá trị > 0, có nghĩa là thực thi các câu lệnh insert/ update/ delete.Nếu giá trị = 0, có nghĩa là thực thi các câu lệnh insert/ update/ delete không có dòng nào bị ảnh hưởng hoặc thực thi câu lệnh cập nhật data structure.Nếu giá trị = -1, có nghĩa là thực thi câu lệnh select. Khi đó, có thể gọi tiếp lệnh statement.getResultSet() để lấy ResultSet.Ví dụ:
int numberRowsAffected = st.executeUpdate(sqlInsert); if (numberRowsAffected == 0) { System.out.println("insertion failed"); } else { System.out.println("inserted successfully : " + sqlInsert); }Đóng kết nối (Close Connection)Cuối cùng, sau khi đã sử dụng chúng ta cần phải gọi phương thức close() để đóng kết nối (Connection) và giải phóng tài nguyên.
Bằng cách đóng kết nối, các đối tượng của Statement và ResultSet sẽ được đóng tự động. Tuy nhiên, chúng ta nên tập thói quen close() Statement sau khi sử dụng hay vì chờ đợi điều đó xảy ra khi nó tự động bị đóng để giải phóng tài nguyên. Đặc biệt nếu chúng ta thực thi Statement trong vòng lặp, thì có thể sẽ gặp vấn đề về thiếu tài nguyên sử dụng nếu chờ đợi nó tự động đóng.
Khi Statement được close() thì ResultSet của Statement cũng được close.
Chương trình Java kết nối cơ sử dữ liệu sử dụng JDBC API
Chương trình bên dưới chỉ đơn giản thực hiện kết nối đến cơ sở dữ liệu MySQL và thêm một dòng dữ liệu vào bảng user.
Xem thêm: Đọc Truyện Bồ Câu Không Đưa Thư, Đọc Sách Truyện Bồ Câu Không Đưa Thư
package com.gpcoder; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; public class HelloJdbc { private static final String hostName = "localhost"; private static final String dbName = "jdbcdemo"; private static final String userName = "root"; private static final String password = ""; // jdbc:mysql://hostname:port/dbname private static final String connectionURL = "jdbc:mysql://" + hostName + ":3306/" + dbName; public static void main(String<> args) throws ClassNotFoundException, SQLException { // 1. Load Driver // Class.forName("com.mysql.jdbc.Driver"); DriverManager.registerDriver(new com.mysql.cj.jdbc.Driver()); // 2. Open connection Connection con = DriverManager.getConnection(connectionURL, userName, password); // 3. Create Statement Statement st = con.createStatement(); // 4. Execute query String sqlInsert = "INSERT INTO user(username, password, createdDAte) VALUE("gpcoder", "123", now());"; int numberRowsAffected = st.executeUpdate(sqlInsert); if (numberRowsAffected == 0) { System.out.println("insertion failed"); } else { System.out.println("inserted successfully : " + numberRowsAffected); } st.close(); // 5. Close connection con.close(); } }Thực thi chương trình trên ta có kết quả sau:
inserted successfully : 1Lưu ý: các bạn nên đặt câu lệnh close() trong finally block trong câu lệnh try-catch-finally hoặc sử dụng tính năng mới try-with-resource để đảm bảo resource luôn được close sau khi sử dụng. Ví dụ:
package com.gpcoder; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; public class HelloJdbcWithJava8 { private static final String hostName = "localhost"; private static final String dbName = "jdbcdemo"; private static final String userName = "root"; private static final String password = ""; // jdbc:mysql://hostname:port/dbname private static final String connectionURL = "jdbc:mysql://" + hostName + ":3306/" + dbName; public static void main(String<> args) throws ClassNotFoundException, SQLException { // 1. Load Driver // Class.forName("com.mysql.jdbc.Driver"); DriverManager.registerDriver(new com.mysql.cj.jdbc.Driver()); try ( // 2. Open connection Connection con = DriverManager.getConnection(connectionURL, userName, password); // 3. Create Statement Statement st = con.createStatement(); ) { // 4. Execute query String sqlInsert = "INSERT INTO user(username, password, createdDAte) VALUE("gpcoder", "123", now());"; int numberRowsAffected = st.executeUpdate(sqlInsert); if (numberRowsAffected == 0) { System.out.println("insertion failed"); } else { System.out.println("inserted successfully : " + numberRowsAffected); } } // 5. Close connection: will be auto closed by try-with-resource } }Trên đây là một số kiến thức cơ bản về kết nối cơ sở dữ liệu với Java JDBC. Trong bài viết tiếp theo, chúng ta sẽ cùng tìm hiểu sâu hơn về các API của JDBC.