In previous posts, we have learned about types of JDBC drivers and the how to make database connection using JDBC and then how to execute SELECT Query. Let’s move forward. In this example I am picking up execution of SQL INSERT queries using JDBC.
SQL INSERT query are executed to push/store data stored in relational databases. It requires following steps:
1) Make a database connection
2) Execute the SQL INSERT Query
Pr-requisites include setting up a database schema and creating a table at least.
CREATE SCHEMA 'JDBCDemo' ; CREATE TABLE 'JDBCDemo'.'EMPLOYEE' ( 'ID' INT NOT NULL DEFAULT 0 , 'FIRST_NAME' VARCHAR(100) NOT NULL , 'LAST_NAME' VARCHAR(100) NULL , 'STAT_CD' TINYINT NOT NULL DEFAULT 0 );
Let’s write above steps in code:
1) Make a database connection
Though we have already learned about it in making JDBC connection, lets recap with this simple code snippet.
Class.forName("com.mysql.jdbc.Driver"); connection = DriverManager .getConnection("jdbc:mysql://localhost:3306/JDBCDemo", "root", "password");
2) Execute the SQL INSERT Query
This is the main step and core part in ths post. It requires creating a Statement object and then using it’s execute() method.
Statement stmt = connection.createStatement(); stmt.execute("INSERT INTO EMPLOYEE (ID,FIRST_NAME,LAST_NAME,STAT_CD) VALUES (1,'Lokesh','Gupta',5)");
Above statement will execute an insert statement in database we are connected to.
Let’s see the whole code in working.
package com.howtodoinjava.jdbc.demo; import java.sql.Connection; import java.sql.DriverManager; import java.sql.Statement; public class InsertDataDemo { public static void main(String[] args) { Connection connection = null; Statement stmt = null; try { Class.forName("com.mysql.jdbc.Driver"); connection = DriverManager .getConnection("jdbc:mysql://localhost:3306/JDBCDemo", "root", "password"); stmt = connection.createStatement(); stmt.execute("INSERT INTO EMPLOYEE (ID,FIRST_NAME,LAST_NAME,STAT_CD) " + "VALUES (1,'Lokesh','Gupta',5)"); } catch (Exception e) { e.printStackTrace(); }finally { try { stmt.close(); connection.close(); } catch (Exception e) { e.printStackTrace(); } } } }
That’s all in this post. Drop me a comment if something needs explanation.
Happy Leaning !!
Leave a Reply