通过socket访问数据库

通过套接字访问数据库

提示:通过socket访问数据库分为三类:Clinet、Display和SQL Server。

Client.Java

导入Java . awt . *；
导入Java . io . *；
导入Java . net . *；
导入Java . applet . *；

公共类客户端扩展Applet
{
public TextArea chat _ txt；
私有TextField sql _ txt
私有按钮连接，执行；
私有套接字soc = null
private PrintStream PS = null；
听听；

public void init()
{
chat _ txt = new TextArea()；
SQL _ txt = new TextField(20)；
Connect = new Button(" Connect ")；
Execute = new Button(" Execute ")；
execute . disable()；

Panel PP = new Panel()；
PP . set layout(new FlowLayout())；
PP . add(SQL _ txt)；
pp.add(连接)；
pp.add(执行)；

加(“北”，PP)；
add("Center "，chat _ txt)；
}

公共布尔操作(Event evt，Object obj)
{
if(evt . target instance of Button)
{
String label =(String)obj；
if(label . equals(" Connect "))
{

try {
SOC = new Socket(inet address . getlocalhost()，4700)；
PS = new print stream(SOC . get output stream())；
PS . println(" HELLO ")；
PS . flush()；
listen= new Listen(这个，SOC)；
listen . start()；
} catch(Exception e)
{
chat _ txt . settext(e . tostring())；
disconnect()；
}
connect . set label(" Disconnect ")；
execute . enable()；
} else if(label . equals(" Disconnect "))
Disconnect()；
else if(label . equals(" Execute "))
{
if(SQL _ txt . gettext()！= null)
{
PS . println(" FIND ")；
PS . flush()；
PS . println(SQL _ txt . gettext())；
PS . flush()；
}
}
}
返回false
}

public void disconnect()
{
if(SOC！= null)
{
try {
listen . stop()；
PS . println(" QUIT ")；
PS . flush()；
SOC . close()；
} catch(Exception e){ }
finally {
listen . stop()；
listen = null；
SOC = null；
}
execute . disable()；
connect . set label(" Disconnect ")；
}
}
}