Insert record using Statement in Java

We saw how to Create Table using Statement in Java.
Now lets insert data into this table using Statement.

Insert record SQL

Below is the query that can be fired directly on database to insert record.

INSERT INTO employee_details (id,first_name,last_name,designation,salary)
VALUES (1,'John','Doe','Engineer','10000');

1 2	INSERT INTO employee_details (id,first_name,last_name,designation,salary) VALUES (1,'John','Doe','Engineer','10000');

Method from Statement Interface used

int executeUpdate(String sql)

1	int executeUpdate(String sql)

“Executes the given SQL statement, which may be an INSERT, UPDATE, or DELETE statement or an SQL statement that returns nothing, such as an SQL DDL statement.”

Now lets see the sample code for firing this SQL using JDBC

Example : Insert record using Statement in Java

package com.kscodes.sampleproject.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class StatementInsertExample {

	public static String DRIVER_CLASS_NAME = "com.mysql.jdbc.Driver";
	public static String CONNECTION_URL = "jdbc:mysql://localhost:3306/mysql";
	public static String CONNECTION_USER = "kscodes";
	public static String CONNECTION_PASSWORD = "kscodes";

	public static void main(String[] args) {

		String insertSql = "INSERT INTO employee_details"
				+ " (id,first_name,last_name,designation,salary) "
				+ " VALUES (1,'John','Doe','Engineer','10000')";

		try (Connection connection = getConnection();
				Statement statement = connection.createStatement()) {

			int rowCount = statement.executeUpdate(insertSql);

			System.out.println("Record inserted successfully in database. Row Count returned is :: "
							+ rowCount);

		} catch (SQLException e) {
			System.out.println("An exception occurred while inserting data in Table. Exception is :: "
							+ e);
		}

	}

	public static Connection getConnection() {

		try {
			Class.forName(DRIVER_CLASS_NAME);
		} catch (ClassNotFoundException e) {
			System.out.println("Error while registering JDBC driver");
			return null;
		}

		Connection connection = null;
		try {
			connection = DriverManager.getConnection(CONNECTION_URL,
					CONNECTION_USER, CONNECTION_PASSWORD);

		} catch (SQLException e) {
			System.out.println("Failed to create Connection");
			return null;
		}
		System.out.println("Connection created Successfully.");

		return connection;
	}

}

package com.kscodes.sampleproject.jdbc;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

public class StatementInsertExample {

public static String DRIVER_CLASS_NAME = "com.mysql.jdbc.Driver";

public static String CONNECTION_URL = "jdbc:mysql://localhost:3306/mysql";

public static String CONNECTION_USER = "kscodes";

public static String CONNECTION_PASSWORD = "kscodes";

public static void main(String[] args) {

String insertSql = "INSERT INTO employee_details"

+ " (id,first_name,last_name,designation,salary) "

+ " VALUES (1,'John','Doe','Engineer','10000')";

try (Connection connection = getConnection();

Statement statement = connection.createStatement()) {

int rowCount = statement.executeUpdate(insertSql);

System.out.println("Record inserted successfully in database. Row Count returned is :: "

+ rowCount);

} catch (SQLException e) {

System.out.println("An exception occurred while inserting data in Table. Exception is :: "

+ e);

}

public static Connection getConnection() {

try {

Class.forName(DRIVER_CLASS_NAME);

} catch (ClassNotFoundException e) {

System.out.println("Error while registering JDBC driver");

return null;

}

Connection connection = null;

try {

connection = DriverManager.getConnection(CONNECTION_URL,

CONNECTION_USER, CONNECTION_PASSWORD);

} catch (SQLException e) {

System.out.println("Failed to create Connection");

return null;

}

System.out.println("Connection created Successfully.");

return connection;

}

Output

Connection created Successfully.
Record inserted successfully in database. Row Count returned is :: 1

1 2	Connection created Successfully. Record inserted successfully in database. Row Count returned is :: 1

Since we have JDK 7, we are using Try-with-resources Statement to handle the resources that are opened.

Reference

1. Statement executeUpdate()