Mysql
 sql >> Base de données >  >> RDS >> Mysql

Exemple d'instruction d'utilisation de l'exemple de création de table JDBC

Cet article contient un exemple Java d'utilisation de java.sql.Statement pour exécuter créer des scripts SQL de table MySQL.

1. Extraits de code de déclaration JDBC

  1. L'extrait de code source Java ci-dessous montre comment créer la java.sql.Connection objet et créez le java.sql.Statement  objet et exécutez un script SQL via 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. Code Java complet

  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. Résultat d'exécution.

  1. Lorsque l'exécution du code est terminée, vous pouvez voir que la table enseignant a été créé sous la base de données de test MySQL.
  2. Vous pouvez lire l'article Comment utiliser JDBC pour connecter la base de données MySql pour en savoir plus sur le fonctionnement de MySQL JDBC.