Java programs
DATE CLIENT
import java.io.*;
import java.lang.*;
import java.util.*;
import java.net.*;
class dclient
{
public static void main(String as[])throws Exception
{
Date d=new Date();
String s1=d.toString();
ServerSocket ss=new ServerSocket(1080);
Socket s=ss.accept();
PrintWriter out=new PrintWriter( new OutputStreamWriter(s.getOutputStream()),true);
out.println(s1);
s.close();
//System.out.println(s);
}
}
DATE SERVER
import java.net.*;
import java.io.*;
class dserver
{
public static void main(String df[])throws Exception
{
InetAddress a=InetAddress.getLocalHost();
Socket s=new Socket(a,1080);
BufferedReader in=new BufferedReader(new InputStreamReader(s.getInputStream()));
//PrintWriter out=new PrintWriter(new OutputStreamWriter(s.getOutputStream()),true);
System.out.println(in.readLine());
s.close() ;
}
}
OUTPUT
Client Side:
C:\jdk1.3\bin>javac dclient.java
C:\jdk1.3\bin>java dclient
Serverside:
C:\jdk1.3\bin>javac dserver.java
C:\jdk1.3\bin>java dserver
Mon Oct 16 15:16:39 GMT +05:30 2006
SMTP CLIENT
import java.io.*;
import java.net.*;
import java.util.*;
public class smtpclient
{
public static void main(String args[]) throws Exception
{
Socket s = new Socket("localhost",8080);
String req = null, res = null;
DataInputStream din = new DataInputStream(s.getInputStream());
PrintStream ps = new PrintStream(s.getOutputStream());
DataInputStream in = new DataInputStream(new BufferedInputStream
(System.in));
System.out.println("Connected");
req = din.readLine();
System.out.println(req);
res = in.readLine();
ps.println(res);
req = din.readLine();
System.out.println(req);
res = in.readLine();
ps.println(res);
req = din.readLine();
System.out.println(req);
res = in.readLine();
ps.println(res);
while(true)
{
res = in.readLine();
ps.println(res + "\n");
if(res.equals("quit"))
break;
}
System.out.println("Message accepted for delivery");
}
}
SMTP SERVER
import java.io.*;
import java.net.*;
import java.util.*;
public class smtpserver
{
public static void main(String args[]) throws Exception
{
ServerSocket ss = new ServerSocket(8080);
Socket s = ss.accept();
String req = null, res = null;
DataInputStream din = new DataInputStream(s.getInputStream());
PrintStream ps = new PrintStream(s.getOutputStream());
FileWriter fw = new FileWriter("t.eml");
System.out.println("Connected");
ps.println("From:");
res = din.readLine();
fw.write("From: " + res + "\n");
ps.println("To:");
res = din.readLine();
fw.write("To: " + res + "\n");
ps.println("Subject: ");
res = din.readLine();
fw.write("Subject: " + res + "\n\n\n\n");
while(!(res = din.readLine()).equals("quit"))
fw.write(res);
fw.close();
System.out.println("Message accepted for delivery");
}
}
OUTPUT:
CLIENTSIDE:
C:\j2sdk1.4.1_04\bin>javac smtpclient.java
C:\j2sdk1.4.1_04\bin>java smtpclient
Connected
From:
seetha_mismin@yahoo.com
To:
vinfero@rediffmail.com
Subject:
hai
have a nice day
quit
Message accepted for delivery
SERVER SIDE:
C:\j2sdk1.4.1_04\bin>javac smtpserver.java
C:\j2sdk1.4.1_04\bin>java smtpserver
Connected
Message accepted for delivery
OUT OF BAND CLIENT
import java .net.*;
import java.io.*;
import java.lang.*;
public class oobclient
{
public static void main(String args[])
{
String s = null;
String text = null;
try
{
InetAddress ia = InetAddress.getLocalHost();
DataInputStream dis = new DataInputStream(System.in);
byte d = (byte) 0XFF;
s = "XXXX" + dis.readLine();
byte[] data = new byte [s.length()];
s.getBytes(0,s.length(),data,0);
for (int i=0; i<4; i++)
data [i] =d;
DatagramPacket dp = new DatagramPacket(data,data.length,ia,8020);
DatagramSocket ds = new DatagramSocket(8021);
ds.send(dp);
System.out.println("Data Send");
data = new byte[1024];
dp= new DatagramPacket (data,data.length);
ds.receive(dp);
text = new String(dp.getData());
System.out.println("Received Data: "+text);
}
catch (Exception e)
{
System.out.println(e);
}
}
}
OUT OF BAND SERVER
import java.net.*;
import java.io.*;
public class oobserver
{
public static byte[] msg = new byte[1024];
public static void main(String args[])
{
String str;
DatagramPacket dp = null;
try
{
InetAddress ia = InetAddress.getLocalHost();
DatagramSocket ds = new DatagramSocket (8020);
dp = new DatagramPacket (msg,msg.length);
ds.receive(dp);
str = new String (dp.getData(),0,dp.getLength());
System.out.println("Received Data:"+str);
byte[] data = new byte [str.length()];
str.getBytes(4,str.length(),data,0);
dp = new DatagramPacket(data,data.length,ia,8021);
ds.send(dp);
}
catch (Exception e)
{
System.out.println(e);
}
}
}
OUTPUT
SERVER SIDE:
C:\j2sdk1.4.1_04\bin>javac oobserver.java
C:\j2sdk1.4.1_04\bin>java oobserver
Received Data: hai have a nice day
CLIENT SIDE:
C:\j2sdk1.4.1_04\bin>javac oobclient.java
C:\j2sdk1.4.1_04\bin>java oobclient
hai have a nice day
Data Send
Received Data: hai have a nice day
CHECKSUM CLIENT:
import java io.*;
import java.util.*;
import java.net.*;
import java.util.zip.*;
public class checkclient
{
public static void main(String args[])
{
try
{
Socket so=new Socket(InetAddress.getLocalHost(),8080);
BufferedReader in=new BufferedReader(new
InputStreamReader(so.getInputStream()));
PrintWriter out=new PrintWriter(new BufferedWriter(new
OutputStreamWriter(so.getOutputStream())),true);
String str=args[0];
CRC32 c=new CRC32();
c.update(str.getBytes());
for(int i=1;i<args.length;i++)
{
str=str+"||"+args[i];
c.update(args[i].getBytes());
}
String msg=str+"||"+c.getValue();
out.println(msg);
String st=in.readLine();
System.out.println(st);
}
catch(Exception e)
{
System.out.println(e);
}
}
}
CHECKSUM SERVER
import java.io.*;
import java.net.*;
import java.util.*;
import java.util.zip.*;
public class checkserver
{
ServerSocket ss=null;
public static void main(String args[])
{
Socket s=null;
BufferedReader in=null;
PrintWriter out=null;
try
{
ServerSocket ss=new ServerSocket(8080);
s=ss.accept();
in=new BufferedReader(new InputStreamReader(s.getInputStream()));
out=new PrintWriter(new BufferedWriter(new
OutputStreamWriter(s.getOutputStream())),true);
String str=in.readLine();
StringTokenizer st=new StringTokenizer(str,"||");
int count=st.countTokens();
CRC32 c=new CRC32();
String temp;
for(int i=1;i<count;i++)
{
temp=st.nextElement().toString();
System.out.println(temp);
c.update(temp.getBytes());
}
String chvalRecord=st.nextElement().toString();
String chvalPresent=Long.toString(c.getValue());
if(chvalRecord.equals(chvalPresent))
out.println("Read Data Without Error"+chvalPresent);
else
out.println("Read Data With loss");
}
catch(Exception e)
{
System.out.println(e);
}
}
}
OUTPUT:
CLINET SIDE:
checkclient hai how are you
Read Data Without Error4227075248
SERVERSIDE:
C:\new>java checkserver
hai
how
are
you
UDP CLIENT:
import java.net.*;
import java.io.*;
import java.util.*;
class udpclient
{
public static void main(String args[])
{
try
{
DatagramPacket dp;
String strline,text;
InetAddress ia=InetAddress.getLocalHost();
DataInputStream dis=new DataInputStream(System.in);
System.out.println("enter the string:");
strline=dis.readLine();
byte[] data=new byte[strline.length()];
strline.getBytes(0,strline.length(),data,0);
dp=new DatagramPacket(data,data.length,ia,100);
DatagramSocket ds=new DatagramSocket(101);
ds.send(dp);
System.out.println("data sent");
data=new byte[1024];
dp=new DatagramPacket(data,data.length);
ds.receive(dp);
text=new String(dp.getData(),0,0,dp.getLength());
System.out.println(text);
}
catch(UnknownHostException e)
{
System.out.println(e);
}
catch(SocketException e)
{
System.out.println(e);
}
catch(IOException e)
{
System.out.println(e);
}
}
}
UDP SERVER :
import java.net.*;
import java.io.*;
class udpserver
{
public static byte[] msg=new byte[1024];
public static void main(String args[])
{
String str;
try
{
InetAddress ia=InetAddress.getLocalHost();
DatagramPacket dp=new DatagramPacket(msg,msg.length);
DatagramSocket ds=new DatagramSocket(100);
ds.receive(dp);
str=new String(dp.getData(),0,0,dp.getLength());
System.out.println(str);
byte[] data=new byte[str.length()];
str.getBytes(0,str.length(),data,0);
dp=new DatagramPacket(data,data.length,ia,101);
ds.send(dp);
}
catch(SocketException e)
{
System.out.println(e);
}
catch(IOException ie)
{
System.out.println(ie);
}
}
}
OUTPUT:
CLIENT SIDE:
C:\j2sdk1.4.1_04\bin>javac udpclient.java
C:\j2sdk1.4.1_04\bin>java udpclient
enter the string:
welcome to MTECH IT
data sent
welcome to MTECH IT
SERVER SIDE:
C:\j2sdk1.4.1_04\bin>javac udpserver.java
C:\j2sdk1.4.1_04\bin>java udpserver
welcome to MTECH IT
SERVER COOKIE
import java.io.*;
import java.net.*;
import java.util.*;
public class scook
{
public static void main(String args[]) throws Exception
{
ServerSocket ss = new ServerSocket(8080);
Socket s = null;
String name = null,issecure = null,expries = null,domain = null,path = null,cookie = null,request = null,value = null;
try
{
s = ss.accept();
System.out.println("client connected....");
DataInputStream din = new DataInputStream(s.getInputStream());
DataOutputStream dout = new DataOutputStream(s.getOutputStream());
name = "TEST COOKIE";
value = "ABCHHRSKJUD";
expries = new Date().toString();
domain = "LOCALHOST";
path = "/";
issecure = "TRUE";
cookie = "set-cookie:NAME="+name+";VALUE="+value+";EXPIRES="+expries+"; DOMAIN="+domain+";PATH="+path+";ISSECURE="+issecure;
request = din.readLine();
System.out.println("RECEIVING>>>>>>>>"+request);
if(request.startsWith("get"))
{
System.out.println("SENDING>>>>>>>>>>"+request.substring(4));
System.out.println("SENDING COOKIEE.....");
dout.writeBytes(cookie+"\n");
}
request = din.readLine();
System.out.println("RECEIVING>>>>>>"+cookie);
if(request.startsWith("cookie"))
{
expries = new Date().toString();
cookie = "set-cookie:NAME="+name+";VALUE="+value+";EXPIRES="+expries+"; DOMAIN="+domain+";PATH="+path+";ISSECURE="+issecure;
}
System.out.println("SENDING COOKIE...........");
dout.writeBytes(cookie+"\n");
}
catch(Exception e)
{
System.out.println(e);
}
}
}
ClientCookie:
import java.io.*;
import java.net.*;
import java.util.*;
public class ccook
{
public static void main(String args[]) throws Exception
{
Socket s = new Socket("localhost",8080);
String response = null;
try
{
DataInputStream din = new DataInputStream(s.getInputStream());
DataOutputStream dout = new DataOutputStream(s.getOutputStream());
System.out.println("SENDING REQUEST MSG:");
dout.writeBytes("get http:/www.google.co.in\n");
System.out.println("READING
response = din.readLine();
System.out.println(response);
Thread.sleep(5000);
System.out.println("SENDING COOKIE REQUEST");
dout.writeBytes("cookie:\n");
System.out.println("READING
response = din.readLine();
System.out.println(response);
}
catch(Exception e)
{
System.out.println(e);
}
}
}
OUTPUT:
CLIENT SIDE:
C:\coo>javac ccook.java
C:\coo>java ccook
SENDING REQUEST MSG:
READING COOKIE
set-cookie:NAME=TEST COOKIE;VALUE=ABCHHRSKJUD;EXPIRES=Tue Sep 19 13:39:15 GMT +05
:30 2006; DOMAIN=LOCALHOST;PATH=/;ISSECURE=TRUE
SENDING COOKIE REQUEST
READING COOKIE
set-cookie:NAME=TEST COOKIE;VALUE=ABCHHRSKJUD;EXPIRES=Tue Sep 19 13:39:20 GMT +05
:30 2006; DOMAIN=LOCALHOST;PATH=/;ISSECURE=TRUE
SERVER SIDE:
C:\coo>javac scook.java
C:\coo>java scook
client connected....
RECEIVING>>>>>>>>get http:/www.google.co.in
SENDING>>>>>>>>>>http:/www.google.co.in
SENDING COOKIEE.....
RECEIVING>>>>>>set-cookie:NAME=TEST COOKIE;VALUE=ABCHHRSKJUD;EXPIRES=Tue Sep 19
SENDING COOKIE...........
TELNET CLIENT:
import java.util.*;
import java.io.*;
import java.net.*;
public class tclient
{
public static void main(String args[])throws Exception
{
InetAddress ia=InetAddress.getLocalHost();
Socket s=new Socket(ia,8080);
System.out.println("client"+s);
DataInputStream dis=null;
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(s.getOutputStream())),true);
dis=new DataInputStream(System.in);
//String inputline;
String command;
System.out.println(br.readLine());
out.println("telnet");
//inputlintline=br.readLine();
//login//
System.out.println(br.readLine());
String login=dis.readLine();
out.println(login);
//password//
System.out.println(br.readLine());
String password=dis.readLine();
out.println(password);
//enter the command//
System.out.println("enter the command");
command=dis.readLine();
out.println(command);
if(command.equals("dir"))
{
while(true)
{
String str=br.readLine();
System.out.println(str);
if(str.equals("end"))
break;
}
}
s.close();
}
}
TELNET SERVER:
import java.net.*;
import java.io.*;
import java.util.*;
class tserver
{
public static void main(String args[])
{
ServerSocket ss=null;
Socket s=null;
try
{
ss=new ServerSocket(8080);
while(true)
{
s=ss.accept();
String name="";
String password, command;
BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
System.out.println("io readerintialized");
PrintWriter out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(s.getOutputStream())),true);
System.out.println("io writer intialized");
//String inputline;
//System.out.println("value accepted");
//inputline=br.readLine();
//System.out.println(inputline);
out.println("hello telnet started");
System.out.println(br.readLine());
out.println("login");
name=br.readLine();
System.out.println(name);
out.println("password");
password=br.readLine();
System.out.println(password);
if((password.equals("admin"))&&(name.equals("admin")))
{
out.println("u r entered");
}
while(true)
{
command=br.readLine();
System.out.println(command);
if(command.equals("quit"))
{
out.println("bye");
break;
}
else if(command.equals("dir"))
{
File toofile=new File("\\");
String[] file=toofile.list();
for(int i=1;i<file.length;i++)
{
out.println(file[i]);
}
System.out.println("end");
break;
}
}
}
}
catch(Exception e)
{
System.out.println(e);
}
}
}
OUTPUT:
CLIENT SIDE:
C:\j2sdk1.4.1_04\bin>javac tclient.java
C:\j2sdk1.4.1_04\bin>java tclient
clientSocket[addr=syst1/10.64.0.151,port=8080,localport=1255]
hello telnet started
login
admin
password
admin
enter the command
dir
u r entered
MSDOS.SYS
COMMAND.COM
BOOTLOG.TXT
WINNT
BOOTLOG.PRV
LAN
SERVER SIDE:
C:\j2sdk1.4.1_04\bin>javac tserver.java
C:\j2sdk1.4.1_04\bin>java tserver
io readerintialized
io writer intialized
telnet
admin
admin
dir
end
WEB CLIENT:
import java.io.*;
import java.net.*;
public class webclient
{
public static void main(String args[])
{
try
{
Socket clientSocket1=new Socket("localhost",80);
System.out.println("Client1:"+clientSocket1);
getPage(clientSocket1);
}
catch(UnknownHostException uhe)
{
System.out.println("UnknownHostException: " + uhe);
}
catch(IOException ioe)
{
System.err.println("IOException"+ioe);
}
}
public static void getPage(Socket clientSocket)
{
try
{
DataOutputStream outbound=new DataOutputStream(clientSocket.getOutputStream());
DataInputStream inbound=new DataInputStream(clientSocket.getInputStream());
// outbound.writeBytes("GET/HTTP/1.0\r\n\r\n");
String responseLine;
while((responseLine=inbound.readLine())!=null)
{
System.out.println(responseLine);
break;
}
// cleanup
outbound.close();
inbound.close();
clientSocket.close();
}
catch(IOException ioe)
{
System.out.println("IOException: " +ioe);
}
}
}
WEBSERVER:
import java.net.*;
import java.io.*;
class webserver
{
public static void main(String args[])
{
ServerSocket serverSocket=null;
Socket clientSocket=null;
int connects=0;
try
{
//Create the server scoket
serverSocket=new ServerSocket(80,5);
while(connects<5)
{
//Waits for a connection
clientSocket=serverSocket.accept();
//Service the connection
ServiceClient(clientSocket);
connects++;
}
serverSocket.close();
}
catch(IOException ioe)
{
System.out.println("Error in Simple Webserver:" + ioe);
}
}
public static void ServiceClient(Socket client)throws IOException
{
DataInputStream inbound=null;
DataOutputStream outbound=null;
try
{
// Acquire the streams for IO
inbound=new DataInputStream(client.getInputStream());
outbound=new DataOutputStream(client.getOutputStream());
// Format the output(response header and tiny HTML docuemtn
String buffer="<html> <body> <p> Welcome to Sample Web Page WELCOME TO M.TECH IT </body> </html>";
String inputLine;
// while((inputLine=inbound.readLine())!=null)
//{
outbound.writeBytes(buffer);
// break;
//}
}
finally
{
//cleanup
System.out.println("Cleaning up connection:" +client);
outbound.close();
inbound.close();
client.close();
client.close();
}
}
}
OUTPUT:
CLIENT SIDE:
C:\j2sdk1.4.1_04\bin>javac webclient.java
C:\j2sdk1.4.1_04\bin>java webclient
Client1:Socket[addr=localhost/127.0.0.1,port=80,localport=23]
<html><body> <p> Welcome to Sample Web Page WELCOME TO M.TECH IT </body> </html>
SERVER SIDE:
C:\jdk1.4\bin>javac webserver.java
C:\jdk1.4\bin>java webserver
Cleaning up connection:Socket[addr=/127.0.0.1,port=1340,localport=80]
Cleaning up connection:Socket[addr=/127.0.0.1,port=1341,localport=80]
RMI
bank Interface:
import java.sql.*;
import java.rmi.*;
public interface bankint extends Remote
{
public Bank getInfo(String accno)throws RemoteException;
}
bankImpl:
import java.sql.*;
import java.rmi.*;
import java.io.*;
import java.rmi.server.*;
public class bankimpl extends UnicastRemoteObject implements bankint
{
Connection con=null;
Statement stmt=null;
ResultSet rs=null;
public bankimpl() throws RemoteException
{
super();
}
public void connect()
{
try
{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
con=DriverManager.getConnection("jdbc:odbc:banksource");
// stmt=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
stmt=con.createStatement();
}
catch(Exception e)
{
}
}
public Bank getInfo(String accno)
{
Bank b=new Bank();
try
{
connect();
System.out.println("Query is executed"+accno );
rs=stmt.executeQuery("select * from bankinfo where accno='"+accno+"'");
rs.next();
b.setAccno(rs.getString(1));
b.setName(rs.getString(2));
// b.setBalance(rs.getString(3));
// b.setCity(rs.getString(4));
}
catch(Exception se)
{
}
return b;
}
}
bankservser:
import java.net.*;
import java.rmi.*;
public class bankser
{
public static void main(String args[])
{
try
{
bankimpl ob1=new bankimpl();
Naming.rebind("bankser",ob1);
}
catch(Exception e)
{
}
}
}
bankclient:
import java.net.*;
import java.rmi.*;
import java.io.*;
public class bankcli
{
public static void main(String args[])
{
try
{
String str="rmi://localhost"+"/bankser";
bankint bk=(bankint) Naming.lookup(str);
Bank b=new Bank();
System.out.println("enter the account number");
DataInputStream dis=new DataInputStream(System.in);
String accno=dis.readLine();
b=bk.getInfo(accno);
System.out.println(b.getAccno());
System.out.println(b.getName());
System.out.println(b.getBalance());
System.out.println(b.getCity());
}
catch(Exception e)
{
System.out.println(e);
}
}
}
bank.java:
import java.io.*;
import java.rmi.*;
public class Bank implements Serializable
{
String accno,name,balance,city;
public Bank()
{
accno=null;
name=null;
balance=null;
city=null;
}
public void setAccno(String acn)
{
accno=acn;
}
public void setName(String n)
{
name=n;
}
public void setBalance(String bal)
{
balance=bal;
}
public void setCity(String c)
{
city=c;
}
public String getAccno()
{
return accno;
}
public String getName()
{
return name;
}
public String getBalance()
{
return balance;
}
public String getCity()
{
return city;
}
}
OUTPUT:
CLIENT SIDE:
C:\ss>javac Bank.java
C:\ss>javac bankint.java
C:\ss>javac bankcli.java
C:\ss>javac bankser.java
C:\ss>rmic bankimpl
C:\ss>start rmiregistry
C:\ss>java bankser
Query is executed12
CLIENT SIDE:
C:\ss>javac bankcli.java
C:\ss>java bankcli
enter the account number
12
12
seetha
5000
nagercoil
JDBC:
import java.awt.*;
import java.awt.event.*;
import java.sql.*;
public class library extends Frame implements ActionListener
{
String bkno,bknme,author,copies;
Label l1,l2,l3,l4,l5;
TextField t1,t2,t3,t4;
Button b1,b2,b3,b4,b5,b6,b7,b8,b9;
int pos=0,count=0,row=0;
Panel p1,p2,p3;
Statement stmt;
Connection con;
ResultSet rset;
public void actionPerformed(ActionEvent ae)
{
if(ae.getSource()==b1)
{
insert();
}
if(ae.getSource()==b2)
{
}
if(ae.getSource()==b4)
{
System.exit(0);
}
if(ae.getSource()==b5)
{
first();
}
if(ae.getSource()==b6)
{
next();
}
if(ae.getSource()==b7)
{
previous();
}
if(ae.getSource()==b8)
{
last();
}
if(ae.getSource()==b9)
{
clear();
}
}
public library(String a)
{
super(a);
p1=new Panel();
p2=new Panel();
b1=new Button("Insert");
b2=new Button("Delete");
b4=new Button("Exit");
b5=new Button("First");
b6=new Button(">>");
b7=new Button("<<");
b8=new Button("Last");
b9=new Button("Clear");
b1.addActionListener(this);
b2.addActionListener(this);
b4.addActionListener(this);
b5.addActionListener(this);
b6.addActionListener(this);
b7.addActionListener(this);
b8.addActionListener(this);
b9.addActionListener(this);
p2.setLayout(new GridLayout(2,4));
p2.add(b1);
p2.add(b2);
p2.add(b4);
p2.add(b5);
p2.add(b6);
p2.add(b7);
p2.add(b8);
p2.add(b9);
l1=new Label("Library Details");
l2=new Label("Bok number");
l3=new Label("Book name");
l4=new Label("Author");
l5=new Label("Availble copies");
t1=new TextField();
t2=new TextField();
t3=new TextField();
t4=new TextField();
p1=new Panel(new GridLayout(5,6));
p3=new Panel(new GridLayout(2,2));
p3.add(l1);
p1.add(l2);
p1.add(t1);
p1.add(l3);
p1.add(t2);
p1.add(l4);
p1.add(t3);
p1.add(l5);
p1.add(t4);
setLayout(new BorderLayout());
add("North",p1);
add("South",p2);
Connect();
}
public void paste()
{
try
{
t1.setText(rset.getString(1));
t2.setText(rset.getString(2));
t3.setText(rset.getString(3));
t4.setText(rset.getString(4));
}
catch(Exception e)
{
e.getMessage();
}
}
public void Connect()
{
try
{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
con=DriverManager.getConnection("jdbc:odbc:librarysource");
stmt=con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
rset=stmt.executeQuery("select * from library");
rset.next();
paste();
}
catch(Exception e)
{
e.getMessage();
}
}
public void insert()
{
try
{
bkno=t1.getText();
bknme=t2.getText();
author=t3.getText();
copies=t4.getText();
String insSQL="Insert into library values('"+bkno+"','"+bknme+"','"+author+"','"+copies+"')";
stmt.executeUpdate(insSQL);
first();
}
catch(Exception e)
{
e.getMessage();
}
}
public void del
{
try
{
String b=t1.getText();
String delSQL="Delete * from library where bkno='"+b+"'";
stmt.execute(delSQL);
first();
}
catch(Exception e)
{
e.getMessage();
}
}
public void exit()
{
exit();
}
public void clear()
{
try
{
t1.setText("");
t2.setText("");
t3.setText("");
t4.setText("");
}
catch(Exception e)
{
e.getMessage();
}
}
public void first()
{
try
{
rset.first();
paste();
}
catch(Exception e)
{
e.getMessage();
}
}
public void previous()
{
try
{
rset.previous();
paste();
}
catch(Exception e)
{
e.getMessage();
}
}
public void last()
{
try
{
rset.last();
paste();
}
catch(Exception e)
{
e.getMessage();
}
}
public void next()
{
try
{
rset.next();
paste();
}
catch(Exception e)
{
e.getMessage();
}
}
public static void main(String args[])
{
library b=new library("library frame");
b.setSize(300,300);
b.setVisible(true);
}
}
OUTPUT:
C:\jdk1.4\bin>javac library.java
C:\jdk1.4\bin>java library
OBJECT BASED SERVER:
OBJECT BANK:
import java.sql.*;
import java.io.*;
public class objectbank implements Serializable
{
String accno, name, gender,balance, date, address;
public void bank()
{
accno=null;
name=null;
gender=null;
balance=null;
date=null;
address=null;
}
public void setAccno(String accno1)
{
accno=accno1;
}
public void setName(String name1)
{
name=name1;
}
public void setGender(String gender1)
{
gender=gender1;
}
public void setBalance(String balance1)
{
balance=balance1;
}
public void setDate(String date1)
{
date=date1;
}
public void setAddress(String address1)
{
address=address1;
}
public String getAccno()
{
return(accno);
}
public String getName()
{
return(name);
}
public String getGender()
{
return(gender);
}
public String getBalance()
{
return(balance);
}
public String getDate()
{
return(date);
}
public String getAddress()
{
return(address);
}
}
OBJECT CLIENT:
import java.io.*;
import java.sql.*;
import java.net.*;
import java.util.*;
class objectclient
{
public static void main(String args[])
{
PrintWriter pw=null;
BufferedReader br=null;
ObjectInputStream in=null;
Socket clientsock=null;
objectbank b=null;
try
{
clientsock=new Socket("localhost",8000);
pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(clientsock.getOutputStream())),true);
DataOutputStream out=new DataOutputStream(clientsock.getOutputStream());
br=new BufferedReader(new InputStreamReader(System.in));
System.out.println("enter the choice all records or num");
String input=br.readLine();
out.writeBytes(input+"\n");
in=new ObjectInputStream(clientsock.getInputStream());
if(input.startsWith("all"))
{
Vector v=null;
v=(Vector)in.readObject();
for(int i=0;i<v.size();i++)
{
b=(objectbank)v.elementAt(i);
System.out.println(b.getAccno());
System.out.println(b.getName());
System.out.println(b.getGender());
System.out.println(b.getAddress());
System.out.println(b.getDate());
System.out.println(b.getBalance());
System.out.println();
}
}
else
{
b=(objectbank)in.readObject();
System.out.println(b.getName());
System.out.println(b.getGender());
System.out.println(b.getAddress());
System.out.println(b.getDate());
System.out.println(b.getBalance());
System.out.println();
}
}
catch(Exception e)
{
System.out.println(e);
}
}
}
Object server:
import java.io.*;
import java.sql.*;
import java.net.*;
import java.util.*;
class objectserver
{
public static void main(String args[]) throws Exception
{
ObjectOutputStream out =null;
String url;
Connection con;
Statement stm;
ResultSet rs;
Vector bank=new Vector();
ServerSocket serversock=new ServerSocket(8000);
Socket clientsock=null;
objectbank b=null;
while(true)
{
try
{
clientsock=serversock.accept();
DataInputStream dis=new DataInputStream(clientsock.getInputStream());
out=new ObjectOutputStream(clientsock.getOutputStream());
String input=dis.readLine();
System.out.println(input);
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
url="jdbc:odbc:banking";
con=DriverManager.getConnection(url);
stm=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
rs=stm.executeQuery("select * from banking");
if(input.equals("all"))
{
rs.first();
do
{
b=new objectbank();
b.setAccno(rs.getString(1));
b.setName(rs.getString(2));
b.setGender(rs.getString(3));
b.setAddress(rs.getString(4));
b.setDate(rs.getString(5));
b.setBalance(rs.getString(6));
bank.addElement(b);
}while(rs.next());
out.writeObject(bank);
}
else
{
b=new objectbank();
rs.first();
do
{
String temp=rs.getString(1);
if(input.equals(temp))
{
b.setName(rs.getString(2));
b.setGender(rs.getString(3));
b.setAddress(rs.getString(4));
b.setDate(rs.getString(5));
b.setBalance(rs.getString(6));
}
}
while(rs.next());
out.writeObject(b);
}
}
catch(Exception e)
{
System.out.println(e);
}
}
}
}
OBJECT BASE0D SERVER:
OUTPUT:
CLIENT SIDE:
C:\jdk1.4\bin>javac objectbank.java
C:\jdk1.4\bin>javac objectclient.java
C:\jdk1.4\bin>javac objectserver.java
C:\jdk1.4\bin>java objectclient
enter the choice all records or num
12
fg
f
dfgdh
2006-12-12 00:00:00
1230
SERVER SIDE:
C:\jdk1.4\bin>javac objectserver.java
C:\jdk1.4\bin>java objectserver
12
CHAT SERVER:
import java.net.*;
import java.io.*;
class chatserver
{
public static void main(String ad[])throws Exception
{
ServerSocket ss;
DataInputStream uin;
DataInputStream din;
PrintStream p;
Socket s;
try
{
ss=new ServerSocket(1711);
s=ss.accept();
din=new DataInputStream(s.getInputStream());
uin=new DataInputStream(System.in);
p=new PrintStream(s.getOutputStream());
String str;
String str1;
while(true)
{
str=din.readLine();
while(!(str.equalsIgnoreCase("end")))
{
System.out.println("Message from Client : " +str);
str1=uin.readLine();
p.println(str1);
str=din.readLine();
}
}
}
catch(IOException e)
{
}
}
}
CHAT CLIENT:
import java.net.*;
import java.io.*;
class chatclient
{
public static void main(String ad[])throws Exception
{
Socket s;
DataInputStream dis;
PrintStream p;
InetAddress i=InetAddress.getLocalHost();
String msg;
s=new Socket(i,1711);
dis=new DataInputStream(s.getInputStream());
p=new PrintStream(s.getOutputStream());
DataInputStream uin=new DataInputStream(System.in);
String str;
str=uin.readLine();
while(!(str.equalsIgnoreCase("end")))
{
p.println(str);
msg=dis.readLine();
System.out.println("Message from Server : " +msg);
str=uin.readLine();
}
}}
OUTPUT
CLIENT SIDE
C:\jdk1.4\bin>javac chatclient.java
C:\jdk1.4\bin>java chatclient
hai how are you
Message from Server : have a nice day
SERVER SIDE
C:\jdk1.4\bin>javac chatserver.java
C:\jdk1.4\bin>java chatserver
Message from Client : hai how are you
have a nice day
Posts
I am Nishanth Singamala, a Software Engineer from India. 
0 comments:
Comment here / Ask your Query !!