JDBC Create Table
In the previous series of the tutorials, we have learnt about creation of the database in Java.
In this example, we are looking into the JDBC database tutorial to create a table in the Database
JDBC Create Table in Database :
package com.c4learn.jdbc; import java.sql.*; public class JDBCCreateTable { // JDBC driver name and database URL static final String JDBC_DRIVER = "com.mysql.jdbc.Driver"; static final String DB = "jdbc:mysql://localhost/student"; // 1. Database User name & Password static final String USER = "admin"; static final String PWD = "password"; public static void main(String[] args) { Connection con = null; Statement statement = null; try { // 2. Register JDBC driver Class.forName("com.mysql.jdbc.Driver"); // 3. Open a connection System.out.println("Connecting to database..."); con = DriverManager.getConnection(DB, USER,PWD); // 4. Execute a query System.out.println("Creating Table.."); statement = con.createStatement(); String sql = "create table user " + "(roll integer not null, " + " first varchar(50), " + " last varchar(50), " + " age integer, " + " primary key ( roll ))"; statement.executeUpdate(sql); System.out.println("Table Created."); } catch (SQLException e) { System.out.println(e.getMessage()); } catch (Exception e) { System.out.println(e.getMessage()); } finally { try { System.out.println("Closing Connection"); if (statement != null) statement.close(); } catch (SQLException e) { } try { if (con != null) con.close(); } catch (SQLException sqlEx) { System.out.println(sqlEx.getMessage()); } } System.out.println("Ending Program.."); } }
Output :
Connecting to database... Creating Table.. Table Created. Closing Connection Ending Program..
Explanation : JDBC Create Table
After the creation of the database in the MySQL, We can add or insert rows into DB. In order to achieve this we need to carry out following steps.
Step 1 : Importing the packages :
When we are dealing with the database connectivity then we need to include the required jar file which is necessary for the database programming.
import java.sql.*;
Step 2 : Registering JDBC driver :
After importing the packages we need to initialize a driver to open a communications channel with the database.
Class.forName("com.mysql.jdbc.Driver");
Step 3 : Open a connection .
DriverManager.getConnection() method is required to create a Connection object.
It represents a physical connection with database server. Below statement is used to create the DB URL -
static final String DB = "jdbc:mysql://localhost/student";
Using below statement we can connect to database physically.
System.out.println("Connecting to database..."); con = DriverManager.getConnection(DB_URL, USER,PWD);
Step 4 : Execute a query .
Below statement will create statement object for executing the query.
statement = con.createStatement();
We have created the following query -
String sql = "create table user " + "(roll integer not null, " + " first varchar(50), " + " last varchar(50), " + " age integer, " + " primary key ( roll ))";
To execute the query using the statement object we can write following line of code -
statement.executeUpdate(sql);
Using the statement object we can create a query and submit it to the database. This query will create specified table in the database.
Step 5 : Clean up the environment .
After the execution of the query we need to clean up the resources. It requires explicitly closing all database resources
if (statement != null) statement.close();
and
if (con != null) con.close();