C/S架构的数据库操作

    最近在做一个课程设计，需要用到C/S架构，客户端发出增删改查数据库的请求，服务端需要完成数据库的具体操作，这样可以保证数据的安全。数据库采用Access，名称为student，放置于F盘根目录下，文件见附件。实现结果如下：

 

服务端：

 客户端：查询到结果为 小文

 

 

实现代码如下：

 

 

ServerFrame.java实现服务端的界面：

import java.awt.*;
import javax.swing.*;
import javax.swing.border.*;
import java.awt.event.*;
/**
*
* @author xwz0528
* 
* 此类主要设置界面
*/

public class ServerFrame extends JFrame{

	public static int port=6000;
	
	Server sev;
	
	public ServerFrame() {
		
		JPanel p1=new JPanel(new GridLayout(2,2));//西
		JLabel jlb1=new JLabel("端口号 ：");
		final JLabel jlbPort=new JLabel("6000");
		JLabel jlb2=new JLabel("运行状态 ：");
		final JLabel jlbNow=new JLabel("关闭");
		p1.add(jlb1);
		p1.add(jlbPort);
		p1.add(jlb2);
		p1.add(jlbNow);
		p1.setBorder(new TitledBorder("服务端信息"));
		
		
		JPanel p2=new JPanel(new GridLayout(3,2));//东
		JPanel p21=new JPanel(new FlowLayout(FlowLayout.CENTER,4,4));
		JLabel jlb3=new JLabel("端口号 ：");
		final JTextField jtfPort=new JTextField("6000",8);		
		p21.add(jlb3);
		p21.add(jtfPort);
		JPanel p22=new JPanel(new FlowLayout(FlowLayout.CENTER,4,4));
		final JButton jbnApply=new JButton("应用");//点击更改端口号
		p22.add(jbnApply);
		JLabel jlb6=new JLabel("");
		p2.add(jlb6);
		p2.add(p21);
		p2.add(p22);
		p2.setBorder(new TitledBorder("设置端口号"));
		
		
		JPanel p3=new JPanel(new GridLayout(2,2));
		JPanel p31=new JPanel(new FlowLayout(FlowLayout.CENTER,4,4));//南
		final JButton jbnStart=new JButton("开启服务");//点击开启服务		
		p31.add(jbnStart);
		JPanel p32=new JPanel(new FlowLayout(FlowLayout.CENTER,4,4));
		final JLabel jlbWork=new JLabel("谢谢使用！");
		p32.add(jlbWork);
		JLabel jlb4=new JLabel("");
		JLabel jlb5=new JLabel("");		
		p3.add(jlb4);
		p3.add(jlb5);
		p3.add(p31);
		p3.add(p32);
		
		setLayout(new BorderLayout());
		add(p1,BorderLayout.WEST);
		add(p2,BorderLayout.EAST);
		add(p3,BorderLayout.SOUTH);
		
		
		
		//以下是消息响应事件
		
		//应用
		jbnApply.addActionListener(new ActionListener(){
			public void actionPerformed(ActionEvent e){
				
				String str=jtfPort.getText();//获得输入的端口号
				
				port=Integer.parseInt(str);
				
				jlbPort.setText(str);//显示新设置的端口号
			}
		});
		
		//开启服务
		jbnStart.addActionListener(new ActionListener(){
			public void actionPerformed(ActionEvent e){
				
				jbnStart.setEnabled(false);
				jbnApply.setEnabled(false);
				jtfPort.setEnabled(false);
				jlbNow.setText("正常运行");
										
				sev=new Server();
				sev.start();
			}
		});
				
	}

	public static void main(String[] args) {
		JFrame frame=new ServerFrame();
		frame.setTitle("企业工资管理系统（ESMS）服务端");
		frame.setSize(380,300);
		frame.setLocationRelativeTo(null);//center
		frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		frame.setVisible(true);
	}

}

 

Server.java实现服务端与客户端的通信：

 

import java.net.*;
import java.io.*;


/**
 *
 * @author xwz0528
 * 
 * 此类的主要功能是完成与客户端的通信功能，接受客户端传来的用于增、删、改、查的sql语句，
 * 
 * 将查询到的信息，以字符串的方式发送给客户端
 */


public class Server extends Thread{
	
	private ServerSocket ss;
	
	private Socket s;
	
	//private volatile boolean isStop=false;//是否运行线程
	
    public Server()
    {
    	
    }
    
    public void run()
    {
    	try
        {
            ss=new ServerSocket(ServerFrame.port);
                       
            //接受消息
            while(true)//线程不停止时(工作)
            {      
            	s=ss.accept();
            	
            	if(s!=null)
            	{
		            InputStream is=s.getInputStream();
		            byte[] buf=new byte[100];	
					int len=is.read(buf);
					if(len!=-1)
					{                               	   
						String sql=new String(buf,0,len);//接受的sql语句
		                   
		                String[] split=sql.split(" ");//根据空格拆分字符串
		                String sqlKey=split[0];//sql语句关键字，判断进行的增删改查操作
		                
		                if(sqlKey.equals("insert")||sqlKey.equals("delete")||sqlKey.equals("update"))
		                {
		                	DataBase.executeSql(sql);
		                }
		                else if(sqlKey.equals("select"))//查询操作
		                {
		                	//发送消息
			                OutputStream os=s.getOutputStream();
		                	
			                String result=DataBase.getQueryResult(sql);
			                
			                os.write(result.getBytes());//执行查询并发送查到的数据	
		                }
		                	                                   
	            	}
            	}
            }
                     
        }
        catch(Exception ex)
        {
            ex.printStackTrace();
        }
    }
}

 

DataBase.java实现数据库的相关操作：

import java.sql.*;

/**
 *
 * @author xwz0528
 * 
 * 此类的主要功能是对数据库进行操作
 */
public class DataBase {

    public static Connection con = null;

    public static Statement st = null;

    public static ResultSet rs; //定义返回结果值

    //连接数据库
    public static void getConn() {
        try {

            String driver = "sun.jdbc.odbc.JdbcOdbcDriver"; //创建驱动程序

            String url = "jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};DBQ=F:\\student.mdb";//创建指定数据库的URL

            Class.forName(driver);

            DataBase.con = DriverManager.getConnection(url);


        } catch (Exception e) {

            e.printStackTrace();


        }
    }

    //关闭数据库连接
    public static void closeConn() {
        try {

            if (DataBase.con != null) {
                DataBase.con.close();
            }

        } catch (Exception e) {

            e.printStackTrace();

        }

    }

    //执行插入（增）、删除（删）、更新（改）语句方法
    public static void executeSql(String sql){

        try{

            DataBase.getConn();

            st = DataBase.con.createStatement();

            st.executeUpdate(sql);//进行非查询操作都为executeUpdate()

            DataBase.con.commit();

            DataBase.closeConn();//关闭数据库连接，以防写不进数据去

        }
        catch(Exception e){

            e.printStackTrace();

        }

    }

    //数据库查询操作，查询方法,返回查询结果集（查）
    public static String getQueryResult(String sql) {

    	String result="";
    	
        try {

            DataBase.getConn();

            st = DataBase.con.createStatement();

            rs = st.executeQuery(sql);//查询操作为executeQuery                                  
            
            while(rs.next())
            {
            	result=rs.getString(2);//姓名
            }
            
            DataBase.closeConn();//关闭数据库连接，以防写不进数据去
            
            return result;


        } catch (Exception e) {

            e.printStackTrace();

            return result;

        }

    }

	
}

 

 

 

 

下面是客户端的测试程序：

Client.java

import java.net.*;
import java.io.*;

public class Client extends Thread{
	
	public static String result="";
	
	public static Socket s;
	
	public Client()
	{
		try
		{
			s=new Socket(InetAddress.getByName("localhost"),6000);
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}	
	}
	
	public void run()
	{
		try
		{						
			//接受消息
            while(true)//线程不停止时(工作)
            {                  	
            	if(s!=null)
            	{
		            InputStream is=s.getInputStream();
		            byte[] buf=new byte[100];	
					int len=is.read(buf);
					if(len!=-1)
					{             						
						Client.result=new String(buf,0,len);
					}
            	}
            }
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}	
	}
	
	public static void send()
	{
		try
		{		
			OutputStream os=s.getOutputStream();      

			//查询学号为356的信息(服务端只实现了返回姓名)
			os.write("select * from db_student where 学号=356".getBytes());
		}
		catch(Exception ex)
		{		
			ex.printStackTrace();	
		}
	}
	
	public static void main(String[] args)
	{
		Thread client=new Client();		
		
		client.start();//一直监听者服务端返回的查询到的信息

		Client.send();//发送sql语句
		
		try
		{
			Thread.sleep(1000);//这个地方不太明白，但是很重要
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}
		
		if(!Client.result.isEmpty())
		{
			System.out.print(Client.result);
		}
	}
}