Hướng dẫn kết nối cơ sở dữ liệu với Java JDBC - GP Coder (Lập trình Java)

Trong bài này tôi sẽ hướng dẫn những bạn sử dụng liên kết vào database sử dụng Java JDBC .

Tóm Tắt

JDBC là gì ?

JDBC (Java Database Connectivity) là một API chuẩn dùng để tương tác với các loại cơ sở dữ liệu quan hệ (database relationship). JDBC bao gồm một tập hợp các class và các interface dùng cho ứng dụng Java có thể giao tiếp với các cơ sở dữ liệu (database) khác nhau.

Bạn đang đọc: Hướng dẫn kết nối cơ sở dữ liệu với Java JDBC – GP Coder (Lập trình Java)

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 gồm có 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

DriverManager : là một class quản lý danh sách các Driver (database drivers). Các yêu cầu kết nối từ ứng dụng Java sẽ được class này tìm kiếm Driver phù hợp đầu tiên để thiết lập kết nối với cơ sở dữ liệu.
Driver: là một interface dùng để xử lý các giao tiếp với cơ sở dữ liệu. Thông thường ứng dụng Java sẽ không giao tiếp trực tiếp với class này mà thông qua DriverManager.
Connection : là một interface cung cấp tất cả các method cần thiết cho việc giao tiếp với database. Interface này chứa nhiều phương thức đa dạng để tạo kết nối với một Database. Tất cả các thông tin giao tiếp với cơ sở dữ liệu chỉ có thể thông qua đối tượng Connection. Một Connection đại diện cho một phiên (session) làm việc với cơ sở dữ liệu.
Statement : là một interface cho phép gửi các câu lệnh SQL tới Database. Ngoài ra, một số Interface kết thừa từ nó cung thêm các tham số để thực thi các thủ tục đã được lưu trữ (stored procedure).
ResultSet : đại diện cho tập hợp các bản ghi (record) có được sau khi thực hiện truy vấn (query).
SQLException : class này xử lý bất cứ lỗi nào xuất hiện trong khi làm việc với Database.

Kết nối database với Java JDBC

Để thao tác với JDBC, bạn cần setup Java và một cơ sở tài liệu ( database ). Bạn hoàn toàn có thể sử dụng bất kể database nào, ví dụ điển hình 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 Driver

Truy cập vào link : https://www.oracle.com/database/technologies/jdbcdriver-ucp-downloads.html

Chọn phiên bản ojdbc[xx].jar tương ứng với phiên bản sử dụng. Chẳng hạn ojdbc6.jar sử dụng cho JDK8, JDK7, và JDK6.

Nếu sử dụng maven project, những bạn hoàn toàn có thể add dependency tương ứng ở link sau : https://mvnrepository.com/artifact/com.oracle.jdbc




    com.oracle.jdbc
    ojdbc14
    12.2.0.1

MySQL Database JDBC Driver

Các bạn thêm maven dependency hoặc tải về gói jar tương ứng tại đây : https://mvnrepository.com/artifact/mysql/mysql-connector-java




    mysql
    mysql-connector-java
    8.0.17

SQL Server ( JTDS ) Database JDBC Driver

Các bạn thêm maven dependency hoặc tải về gói jar tương ứng tại đây : https://mvnrepository.com/artifact/net.sourceforge.jtds/jtds




    net.sourceforge.jtds
    jtds
    1.3.1

PostgreSQL Database JDBC Driver

Các bạn thêm maven dependency hoặc tải về gói jar tương ứng tại đây : https://mvnrepository.com/artifact/org.postgresql/postgresql




    org.postgresql
    postgresql
    42.2.7

MariaDB Database JDBC Driver

Các bạn thêm maven dependency hoặc tải về gói jar tương ứng tại đây : https://mvnrepository.com/artifact/org.mariadb.jdbc/mariadb-java-client




    org.mariadb.jdbc
    mariadb-java-client
    2.4.4

MongoDB Database JDBC Driver

Các bạn thêm maven dependency hoặc tải về gói jar tương ứng tại đây : https://mvnrepository.com/artifact/org.mongodb/mongo-java-driver




    org.mongodb
    mongo-java-driver
    3.11.0

Kết nối database từ Java

Các bước tiếp xúc 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

Để liên kết với database, tất cả chúng ta cần load driver và register nó với ứng dụng. Có 2 cách để thực thi :

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 liên kết ( Open Connection )

Sau khi đã load Driver, tất cả 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)

Xem thêm: SO SÁNH VAR, LET, CONST TRONG JS

Sau khi một liên kết được thiết lập, tất cả chúng ta hoàn toàn có thể tương tác với cơ sở tài liệu .Các interface JDBCStatement, CallableStatement và PreparedStatement xác lập những phương pháp được cho phép gửi những lệnh SQL và nhận tài liệu từ cơ sở tài 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à triển khai câu lệnh truy vấn SQL ( execute query ). Như tất cả chúng ta biết, hoàn toàn 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 ứng một số ít phương pháp để thực thi truy vấn SQL tương ứng với những 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 liên kết ( 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 liên kết, những đối tượng người dùng của Statement và ResultSet sẽ được đóng tự động hóa. Tuy nhiên, tất cả chúng ta nên tập thói quen close ( ) Statement sau khi sử dụng hay vì chờ đón điều đó xảy ra khi nó tự động hóa bị đóng để giải phóng tài nguyên. Đặc biệt nếu tất cả chúng ta thực thi Statement trong vòng lặp, thì hoàn toàn có thể sẽ gặp yếu tố về thiếu tài nguyên sử dụng nếu chờ đón nó tự động hóa đóng .Khi Statement được close ( ) thì ResultSet của Statement cũng được close .

Chương trình Java liên kết cơ sử tài liệu sử dụng JDBC API

Chương trình bên dưới chỉ đơn thuần triển khai liên kết đến cơ sở tài liệu MySQL và thêm một dòng tài liệu vào bảng user .


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ó tác dụng sau :


inserted successfully : 1

Lư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à 1 số ít kỹ năng và kiến thức cơ bản về liên kết cơ sở tài liệu với Java JDBC. Trong bài viết tiếp theo, tất cả chúng ta sẽ cùng tìm hiểu và khám phá sâu hơn về những API của JDBC .

Tài liệu tham khảo:

4.0

Xem thêm: Vòng lặp for, while, do-while trong Java – GP Coder (Lập trình Java)

Nếu bạn thấy hay thì hãy chia sẻ bài viết cho mọi người nhé!

Bình luận

phản hồi

Source: https://final-blade.com
Category: Kiến thức Internet

admin

final-blade.com