Database Creation Example with JDBC Batch


 

Database Creation Example with JDBC Batch

In this example, we are discuss about database creation using JDBC Batch process on the database server.

In this example, we are discuss about database creation using JDBC Batch process on the database server.

Database Creation Example with JDBC Batch:

In this example, we are discuss about database creation using JDBC Batch process on the database server.

First of all, we will create a java class BatchDatabaseCreation.java. In this class we will create database connection as:

Connection connection = null;

Class.forName("com.mysql.jdbc.Driver");

connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/","root","root");

Now we will used sequence of the step for Batch processing for alter database table.

1. Create Statement object using createStatement() method on the created Connection object as:

Statement stmt = connection.createStatement();

2. set auto commit is false using setAutoCommit() as:

connection.setAutoCommit(false);

3. Create MySql create database statement for create new database and add these statement in batch using addBatch() method as:

String dbName = "roseindia_jdbc_tutorials";

String createdatabasequery = "Create Database "+dbName;

stmt.addBatch(createdatabasequery);  

4. Execute the MySql  statements using executeBatch() method on created statement object as:

stmt.executeBatch();

5. Last commit the connection using commit() method as:

connection.commit();

The code of  the BatchDatabaseCreation.java class is:

import java.sql.*;
public class BatchDatabaseCreation {
  
  public static void main(String[] args) {
    try{
        Connection connection = null;
          Class.forName("com.mysql.jdbc.Driver");
    
          connection = DriverManager.getConnection(
               "jdbc:mysql://localhost:3306/"
,"root","root");
          try{            
              // Create statement object  
              Statement stmt = connection.createStatement();            
               
              // Set auto-commit to false
              connection.setAutoCommit(false);
              
              String dbName = "roseindia_jdbc_tutorials";
              
               // create database query 
              String createdatabasequery = "Create Database "+dbName;              
             
              stmt.addBatch(createdatabasequery);              
                      
              stmt.executeBatch();
              
              System.out.println("Database Creation Sucessfully.");
  
             // connection committed
              connection.commit()
          }
          catch (SQLException s){
            System.out.println("SQL Exception " + s);
          }
        }
        catch (Exception e){
          e.printStackTrace();
        }
        
  }

}

Now we will run this example and see the output.

Program output:

The eclipse console output is:

The database is:

Download source code

Ads