Bài viết này chứa một ví dụ java về cách sử dụng java.sql.Statement để thực thi tạo tập lệnh SQL bảng MySQL.
1. Đoạn mã báo cáo JDBC
- Mã nguồn đoạn mã java bên dưới cho biết cách tạo java.sql.Connection và tạo java.sql.Statement và chạy một tập lệnh SQL thông qua java.sql.Statement đối tượng.
/* Get mysql connection object.*/ java.sql.Connection conn = this.getMySqlConnection(ip, port, dbName, userName, password); if(conn!=null) { /* Create Statement object. */ java.sql.Statement stmt = conn.createStatement(); /* Execute create table sql command. */ stmt.execute(createTableSql); }
2. Hoàn thành mã Java
- StatementCreateTableExample.java
public class StatementCreateTableExample { public static void main(String[] args) { StatementCreateTableExample scte = new StatementCreateTableExample(); /* This is the sql command to create mysql table. */ String createMySqlTableSql = "CREATE TABLE `test`.`teacher` ( `name` VARCHAR(100) NOT NULL , `email` VARCHAR(100) NOT NULL ) ENGINE = InnoDB; "; scte.createMySQLTable("localhost", 3306, "test", "root", "", createMySqlTableSql); } /* This method return java.sql.Connection object from MySQL server. */ public Connection getMySqlConnection(String ip, int port, String dbName, String userName, String password) { /* Declare and initialize a sql Connection variable. */ Connection ret = null; try { /* Register for mysql jdbc driver class. */ Class.forName("com.mysql.jdbc.Driver"); /* Create mysql connection url. */ String mysqlConnUrl = "jdbc:mysql://" + ip + ":" + port + "/" + dbName; /* Get the mysql Connection object. */ ret = DriverManager.getConnection(mysqlConnUrl, userName , password); }catch(Exception ex) { ex.printStackTrace(); }finally { return ret; } } public void createMySQLTable(String ip, int port, String dbName, String userName, String password, String createTableSql) { Connection conn = null; Statement stmt = null; try { /* Get mysql connection object.*/ conn = this.getMySqlConnection(ip, port, dbName, userName, password); if(conn!=null) { /* Create Statement object. */ stmt = conn.createStatement(); /* Execute create table sql command. */ stmt.execute(createTableSql); } }catch(Exception ex) { ex.printStackTrace(); }finally { /* Release statment and connection object. This can save system resources. */ try { if(stmt!=null) { stmt.close(); stmt = null; } if(conn!=null) { conn.close(); conn = null; } }catch(Exception ex) { ex.printStackTrace(); } } } }
3. Kết quả thực thi.
- Khi quá trình thực thi mã hoàn tất, bạn có thể thấy rằng bảng giáo viên đã được tạo trong cơ sở dữ liệu thử nghiệm MySQL.
- Bạn có thể đọc bài viết Cách sử dụng JDBC để kết nối cơ sở dữ liệu MySql để tìm hiểu thêm về hoạt động MySQL JDBC.