Share on Google+Share on Google+

Creation and insertion in table

Advertisement
In this program we create table in MYSQL using "create" statement and insert data using "insert " statement query in the created database.

CREATION OF  TABLE,INSERTION &DISPLAY OF DATA  USING SQL QUERY  

In this progam we create table in MYSQL using "create" statement and insert data using "insert " statement query in the created database. Before running this java code you need to paste "mysql-connector-java-3.1.6-bin.jar" file in the jdk1.6.0_01\lib. 

testquery.java

import java.sql.*;

class testQuery {

 public static void main(String[] args) {

  try {
    //URL of the database(ankdb)
    String connectionURL = "jdbc:mysql://192.168.10.13:3306/ankdb";

    // declare a connection by using Connection interface 
    Connection connection = null;

    // declare object of Statement interface that uses for 
//executing sql statements.
    Statement statement = null;

    // declare a resultset that uses as a table
// for output data from the table.
    ResultSet rs = null;
    int updateQuery = 0;

    // Load JDBC driver "com.mysql.jdbc.Driver".
    Class.forName("com.mysql.jdbc.Driver").newInstance();

   
    connection = DriverManager.getConnection(connectionURL, "root", "root");
            

    
    statement = connection.createStatement();

    // sql query of string type to create a data base.
    String QueryString = "CREATE TABLE user1
(User_Id INTEGER NOT NULL AUTO_INCREMENT, " 
+ "User_Name VARCHAR(25),
 UserId VARCHAR(20),User_Pwd VARCHAR(15),
 primary key(User_Id))";

    updateQuery = statement.executeUpdate(QueryString);

    // sql query to insert values in the specified table.
    QueryString = "INSERT INTO user1(User_Name,UserId,User_Pwd) 
VALUES ('Mahendrak',"+ "'mahendra25','1213456')";
    updateQuery = statement.executeUpdate(QueryString);

    if (updateQuery != 0) {
    System.out.println("table is created successfully and " + updateQuery +
 " row is inserted.");
    }

    // sql query to retrieve values from the specified table.  
    QueryString = "SELECT * from user1";
    rs = statement.executeQuery(QueryString);
    while (rs.next()) {
     System.out.println(rs.getInt(1) + 
"" + rs.getString(2) + ""
 + rs.getString(3) + ""
+rs.getString(4)+"\n");
     }

   // close all the connections.
            rs.close();
            statement.close();
            connection.close();
        } 
      catch (Exception ex) {
        System.out.println("Unable to connect to batabase.");
        }
    }
}

output--

Advertisements

Advertisement

Posted on: May 31, 2010 If you enjoyed this post then why not add us on Google+? Add us to your Circles

Share this Tutorial Follow us on Twitter, or add us on Facebook or Google Plus to keep you updated with the recent trends of Java and other open source platforms.