Scribd
Upload
48 views5 pages

Program 4

Uploaded by

omchudasama3688
Copyright
© © All Rights Reserved
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as PDF, TXT or read online on Scribd
48 views5 pages

Program 4

Uploaded by

omchudasama3688
Copyright
© © All Rights Reserved
We take content rights seriously. If you suspect this is your content, claim it here.
Available Formats
Download as PDF, TXT or read online on Scribd
You are on page 1/ 5

Program 4:

(JDBC.Java)
package jdbc;
import java.sql.SQLException;
import java.util.Scanner;
public class JDBC
{
public static void main(String[] args) throws SQLException,
ClassNotFoundException
{
Scanner sc=new Scanner(System.in);
demo d=new demo();
Insert i=new Insert();
Update u=new Update();
Delete dlt =new Delete();
Select s=new Select();

while(true)
{
System.out.println("-Operation-");
System.out.println(": 1. Insert :");
System.out.println(": 2. Update :");
System.out.println(": 3. Delete :");
System.out.println(": 4. Select :");
System.out.println(": 5. Exit :");

System.out.print("Enter your choice :");


int ch=sc.nextInt();

switch(ch)
{
case 1:
i.openConnection();
break;
case 2:
u.openConnection();
break;
case 3:
dlt.openConnection();
break;
case 4:
s.openConnection();
break;
case 5:
System.exit(0);
break;
default:
System.out.println("Invalid Choice.....");
}
}
}
}

(Insert.java)
package jdbc;

import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
public class Insert
{
private Connection conn;
private Statement statement;

public Connection openConnection() throws SQLException,


ClassNotFoundException
{
if(conn==null)
{
String url="jdbc:mysql://localhost:3306/";
String dbName="emp";
String driver="com.mysql.jdbc.Driver";
String username="root";
String password="";

try
{
Class.forName(driver);

this.conn=(Connection)DriverManager.getConnection(url+dbName,username,password);
String str=("INSERT INTO employee(Emp_ID, Emp_Name) VALUES
(?,?)");
PreparedStatement stat=(PreparedStatement)
conn.prepareStatement(str);

Scanner sc=new Scanner(System.in);


System.out.print("Enter Employee ID :");
int id=sc.nextInt();
System.out.print("Enter Employee Name :");
String name=sc.next();

stat.setInt(1, id);
stat.setString(2, name);

int insert=stat.executeUpdate();
if(insert>0)
{
System.out.println("Data Inserted.....");
}
}
catch(SQLException sqle)
{
System.out.println("Connection Failed.....");
}
}
return conn;
}
}

(Update.java)
package jdbc;

import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;

public class Update


{
private Connection conn;
private Statement statement;

public Connection openConnection() throws SQLException,


ClassNotFoundException
{
if(conn==null)
{
String url="jdbc:mysql://localhost:3306/";
String dbName="emp";
String driver="com.mysql.jdbc.Driver";
String username="root";
String password="";

try
{
Class.forName(driver);

this.conn=(Connection)DriverManager.getConnection(url+dbName,username,password);

String str=("UPDATE employee SET Emp_Name=? WHERE Emp_ID=?");


PreparedStatement stat=(PreparedStatement)
conn.prepareStatement(str);

Scanner sc=new Scanner(System.in);

//System.out.print("Enter Employee ID :");


//int id=sc.nextInt();
System.out.print("Enter Employee Name :");
String name=sc.next();

//stat.setInt(1, id);
stat.setString(1, name);

System.out.print("Enter Employee ID :");


int id=sc.nextInt();
stat.setInt(2, id);

int update=stat.executeUpdate();
if(update>0)
{
System.out.println("Data Updated.....");
}
}
catch(SQLException sqle)
{
System.out.println(sqle);
}
}
return conn;
}
}

(Delete.java)
package jdbc;

import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;

public class Delete


{
private Connection conn;
private Statement statement;

public Connection openConnection() throws SQLException,


ClassNotFoundException
{
if(conn==null)
{
String url="jdbc:mysql://localhost:3306/";
String dbName="emp";
String driver="com.mysql.jdbc.Driver";
String username="root";
String password="";

try
{
Class.forName(driver);

this.conn=(Connection)DriverManager.getConnection(url+dbName,username,password);
String str=("DELETE FROM employee WHERE Emp_ID=?");
PreparedStatement stat=(PreparedStatement)
conn.prepareStatement(str);

Scanner sc=new Scanner(System.in);


System.out.print("Enter Employee ID :");
int id=sc.nextInt();

stat.setInt(1, id);

int delete=stat.executeUpdate();
if(delete>0)
{
System.out.println("Data Deleted.....");
}
}
catch(SQLException sqle)
{
System.out.println("Connection Failed.....");
}
}
return conn;
}
}

(Select.java)
package jdbc;

import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;

public class Select


{
private Connection conn;
private Statement statement;

public Connection openConnection() throws SQLException,


ClassNotFoundException
{
if(conn==null)
{
String url="jdbc:mysql://localhost:3306/";
String dbName="emp";
String driver="com.mysql.jdbc.Driver";
String username="root";
String password="";

try
{
Class.forName(driver);

this.conn=(Connection)DriverManager.getConnection(url+dbName,username,password);

String str="SELECT * FROM employee";


Statement stat=(Statement) conn.createStatement();
ResultSet result=stat.executeQuery(str);
while(result.next())
{
int id=result.getInt(1);
String name=result.getString(2);
System.out.println("ID Name");
System.out.println(id+" "+name);
}
}
catch(SQLException sqle)
{
System.out.println("Connection Failed.....");
}
}
return conn;
}
}

You might also like