JDBC Създаване на таблица Пример за използване

Тази статия съдържа java пример за това как да използвате java.sql.Statement за да изпълните SQL скриптове за създаване на таблица MySQL.

1. Кодови фрагменти на JDBC изявление

1. По-долу изходният код на java фрагмент показва как да създадете java.sql.Connection обект и създайте java.sql.Statement обект и изпълнете SQL скрипт чрез java.sql.Statement object.

   /* 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. Пълен Java код

1. 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. Резултат от изпълнението.

1. Когато изпълнението на кода приключи, можете да видите, че таблицата учител е създадено под тестовата база данни MySQL.
2. Можете да прочетете статията Как да използвате JDBC за свързване на MySql база данни, за да научите повече за работата на MySQL JDBC.