import java.sql.*;
import java.util.Scanner;
public class RollBack{
static Connection conn;
static ResultSet rs;
static Statement stmt;
public static void main(String args[])throws Exception{
try{
Class.forName("com.mysql.jdbc.Driver");
conn=DriverManager.getConnection("jdbc:mysql://localhost:3307/Employees","root","root");
Scanner std=new Scanner(System.in);
stmt=conn.createStatement();
stmt.executeUpdate("create table Employee(id int(10) primary key,first varchar(10),last varchar(10))");
conn.setAutoCommit(false);
stmt.execute("insert into Employee values(20,'akshay','kumar')");
stmt.execute("insert into Employee values(21,'akshay','kumar')");
stmt.execute("insert into Employee values(22,'akshay','kumar')");
conn.commit();
stmt.execute("insert into Employee values(23,'akshay','kumar')");
stmt.execute("insert into Employee values(24,'akshay','kumar')");
stmt.execute("insert into Employee values(25,'akshay','kumar')");
conn.rollback();
stmt.execute("insert into Employee values(27,'akshay','kumar')");
stmt.execute("insert into Employee values(29,'akshay','kumar')");
stmt.execute("insert into Employee values(28,'akshay','kumar')");
}
catch(SQLException e)
{
System.out.println(e);
}
finally
{
System.out.println("entered ");
rs=stmt.executeQuery("select * from Employee");
while(rs.next())
{
System.out.println(rs.getInt("id")+" "+rs.getString("first")+" "+rs.getString("last"));
}
stmt.executeUpdate("drop table Employee");
conn.close();
System.out.println("database is closed");
}
}
}