Creation and insertion in table

This section contains the detail about the Creation and insertion in database table using Jdbc.

Creation and insertion in table

In this program, 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.*;

public 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 :

Download Source Code