import java.io.*;
import java.sql.*;
public class Insert
{
int vid,vage,vdid;
String vnm;
Connection conn;
Statement st;
ResultSet rs;
String qry,driver,url;
public void read(int id,String name,int age)
{
vid=id;
vnm=name;
vage=age;
}
public void process()
{
try{
driver="com.mysql.jdbc.Driver"; //mysql database driver
url="jdbc:mysql://localhost/mukesh";
Class.forName(driver);
conn=DriverManager.getConnection(url,"root","kumar");
qry="insert into emp(eid,ename,eage) values("+vid+",'"+vnm+"',"+vage+")";
System.out.println("qry = "+qry);
st=conn.createStatement();
st.executeUpdate(qry);
conn.close();
System.out.println("insertion Done...");
}
catch(Exception e)
{
System.out.println("Error : "+e.getLocalizedMessage());
}
}
public void select()
{
try{
driver="com.mysql.jdbc.Driver"; //mysql database driver
url="jdbc:mysql://localhost/mukesh";
Class.forName(driver);
conn=DriverManager.getConnection(url,"root","kumar");
qry="select * from emp";
System.out.println("qry = "+qry);
st=conn.createStatement();
rs=st.executeQuery(qry);
while(rs.next())
{
int id=rs.getInt("eid");
String nm=rs.getString("ename");
int ag=rs.getInt("eage");
System.out.print(id+" | "+nm+" | "+ag);
System.out.print("\n");
}
rs.close();
conn.close();
System.out.println("selection Done...");
}
catch(Exception e)
{
System.out.println("Error : "+e.getLocalizedMessage());
}
}
void delete(int tdid)
{
vdid=tdid;
try{
driver="com.mysql.jdbc.Driver"; //mysql database driver
url="jdbc:mysql://localhost/mukesh";
Class.forName(driver);
conn=DriverManager.getConnection(url,"root","kumar");
qry="delete from emp where eid="+vdid+"";
System.out.println("qry = "+qry);
st=conn.createStatement();
st.executeUpdate(qry);
conn.close();
System.out.println("deletion Done...");
}
catch(Exception e)
{
System.out.println("Error : "+e.getLocalizedMessage());
}
}
public static void main(String[] args) throws Exception
{
int ch;
InputStreamReader in=new InputStreamReader(System.in);
BufferedReader br=new BufferedReader(in);
System.out.println("1. INSERTION");
System.out.println("2. SELECTION");
System.out.println("3. DELETION");
System.out.println("ENTER UR CHoice ");
ch=Integer.parseInt(br.readLine());
switch(ch)
{
case 1 :
System.out.println("ENTER EMPLOYEE ID : ");
int tid=Integer.parseInt(br.readLine());
System.out.println("ENTER EMPLOYEE NAME : ");
String tnm=br.readLine();
System.out.println("ENTER EMPLOYEE AGE : ");
int tage=Integer.parseInt(br.readLine());
Insert iobj=new Insert();
iobj.read(tid,tnm,tage);
iobj.process();
break;
case 2 :
Insert sobj=new Insert();
sobj.select();
break;
case 3 :
System.out.println("ENTER EMPLOYEE ID : ");
int tdid=Integer.parseInt(br.readLine());
Insert dobj=new Insert();
dobj.delete(tdid);
break;
default: System.out.println("INVALID INPUT") ;
}
}
}
import java.sql.*;
public class Insert
{
int vid,vage,vdid;
String vnm;
Connection conn;
Statement st;
ResultSet rs;
String qry,driver,url;
public void read(int id,String name,int age)
{
vid=id;
vnm=name;
vage=age;
}
public void process()
{
try{
driver="com.mysql.jdbc.Driver"; //mysql database driver
url="jdbc:mysql://localhost/mukesh";
Class.forName(driver);
conn=DriverManager.getConnection(url,"root","kumar");
qry="insert into emp(eid,ename,eage) values("+vid+",'"+vnm+"',"+vage+")";
System.out.println("qry = "+qry);
st=conn.createStatement();
st.executeUpdate(qry);
conn.close();
System.out.println("insertion Done...");
}
catch(Exception e)
{
System.out.println("Error : "+e.getLocalizedMessage());
}
}
public void select()
{
try{
driver="com.mysql.jdbc.Driver"; //mysql database driver
url="jdbc:mysql://localhost/mukesh";
Class.forName(driver);
conn=DriverManager.getConnection(url,"root","kumar");
qry="select * from emp";
System.out.println("qry = "+qry);
st=conn.createStatement();
rs=st.executeQuery(qry);
while(rs.next())
{
int id=rs.getInt("eid");
String nm=rs.getString("ename");
int ag=rs.getInt("eage");
System.out.print(id+" | "+nm+" | "+ag);
System.out.print("\n");
}
rs.close();
conn.close();
System.out.println("selection Done...");
}
catch(Exception e)
{
System.out.println("Error : "+e.getLocalizedMessage());
}
}
void delete(int tdid)
{
vdid=tdid;
try{
driver="com.mysql.jdbc.Driver"; //mysql database driver
url="jdbc:mysql://localhost/mukesh";
Class.forName(driver);
conn=DriverManager.getConnection(url,"root","kumar");
qry="delete from emp where eid="+vdid+"";
System.out.println("qry = "+qry);
st=conn.createStatement();
st.executeUpdate(qry);
conn.close();
System.out.println("deletion Done...");
}
catch(Exception e)
{
System.out.println("Error : "+e.getLocalizedMessage());
}
}
public static void main(String[] args) throws Exception
{
int ch;
InputStreamReader in=new InputStreamReader(System.in);
BufferedReader br=new BufferedReader(in);
System.out.println("1. INSERTION");
System.out.println("2. SELECTION");
System.out.println("3. DELETION");
System.out.println("ENTER UR CHoice ");
ch=Integer.parseInt(br.readLine());
switch(ch)
{
case 1 :
System.out.println("ENTER EMPLOYEE ID : ");
int tid=Integer.parseInt(br.readLine());
System.out.println("ENTER EMPLOYEE NAME : ");
String tnm=br.readLine();
System.out.println("ENTER EMPLOYEE AGE : ");
int tage=Integer.parseInt(br.readLine());
Insert iobj=new Insert();
iobj.read(tid,tnm,tage);
iobj.process();
break;
case 2 :
Insert sobj=new Insert();
sobj.select();
break;
case 3 :
System.out.println("ENTER EMPLOYEE ID : ");
int tdid=Integer.parseInt(br.readLine());
Insert dobj=new Insert();
dobj.delete(tdid);
break;
default: System.out.println("INVALID INPUT") ;
}
}
}
Comments
Post a Comment