04. Các bước sử dụng JDBC để tương tác Cơ sở dữ liệu

Bản quyền thuộc về TITV.vn, 

vui lòng không đăng tải lại nội dung từ trang này.

Video giải thích chi tiết

 Nội dung chi tiết 

Bài 4: Các bước sử dụng JDBC để tương tác Cơ sở dữ liệu

1, Các bước tương tác Cơ sở dữ liệu:

Bước 1: Tạo kết nối với CSDL

Bước 2: Tạo đối tượng statement

+ Xác định câu lệnh SQL

+ Tạo đối tượng statement

Bước 3: Thực thi statement

Bước 4: Xử lý kết quả trả về

Bước 5: Ngắt kết nối

2, Ví dụ

package test;

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

import database.JDBCUtil;

public class TestJDBCUtil {
	public static void main(String[] args) {
		
		try {
			// Bước 1: Tạo kết nối
			Connection connection = JDBCUtil.getConnection();
			
			// Bước 2: Tạo ra đối tượng statement
			Statement st = connection.createStatement();
			
			// Bước 3: Thực thi một câu lệnh SQL
			String sql = "INSERT INTO persons(last_name, first_name, gender, dob, income)"
					+ "VALUES (\"Tran\", \"Thi\", \"C\", \"2000-09-10\", 10000000)";
			
			int check = st.executeUpdate(sql);
			
			// Bước 4: xử lý kết quả 
			System.out.println("Số dòng thay đổi: "+ check);
			if(check>0) {
				System.out.println("Thêm dữ liệu thành công!");
			}else {
				System.out.println("Thêm dữ liệu thất bại!");
			}
			
			// Bước 5: ngắt kết nối
			JDBCUtil.closeConnection(connection);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		
	}
	
	
}



    

package database;

import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.SQLException;

import com.mysql.cj.jdbc.Driver;

public class JDBCUtil {
	public static Connection getConnection() {
		Connection c = null;
		
		try {
			// Đăng ký MySQL Driver với DriverManager
			DriverManager.registerDriver(new com.mysql.jdbc.Driver());
			
			// Các thông số
			String url = "jdbc:mySQL://localhost:3306/ontap";
			String username = "root";
			String password = "";
			
			// Tạo kết nối
			c = DriverManager.getConnection(url, username, password);
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return c;
	}
	
	public static void closeConnection(Connection c) {
		try {
			if(c!=null) {
				c.close();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
	
	public static void printInfo(Connection c) {
		try {
			if(c!=null) {
				DatabaseMetaData mtdt = c.getMetaData();
				System.out.println(mtdt.getDatabaseProductName());
				System.out.println(mtdt.getDatabaseProductVersion());
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}