companyda.java

本工程模拟网上社区,其中包括银行,软件销售公司,软件投资公司,茶餐馆,和多个服务器.

package softwarecompanyserver;

import softwarecompanyserver.CompanyDA;
import softwarecompanyserver.Company;
import java.util.Vector;
import java.sql.*;
import javax.swing.*;
import javax.swing.JOptionPane.*;

public class CompanyDA {
    static Vector companys;
    static Company aCompany;

    static String url = "jdbc:odbc:SoftwareCompany";
    static Connection aConnection;
    static Statement aStatement;

    static String name;
    static String id;
    static String account;   //公司帐户（指注册资金）
    static String num;       //公司员工总数
    static String time;    //公司注册时间
    static String info;    //记录公司简介信息

    public CompanyDA() {
    }

    public static Company findcompany(String key)//throws NotFoundException
    {
        aCompany = null;
        String sqlQuery = "SELECT 公司名称,编号,帐户,员工数,注册时间,信息 FROM CompanyTable WHERE 编号='";
        sqlQuery+=key+"'";
        try
        {
            ResultSet rs = aStatement.executeQuery(sqlQuery);
            boolean gotIt = rs.next();
            if(gotIt)
            {
                    name    = rs.getString(1);
                    id      = rs.getString(2);
                    account = rs.getString(3);
                    num     = rs.getString(4);
                    time    = rs.getString(5);
                    info    = rs.getString(6);
                    //create Company instance
                    aCompany = new Company(name,id,account,num,time,info);
            }
            else
                ;
            rs.close();
        }
        catch(SQLException e)
        { System.out.println(e);}
        return aCompany;
    }

    public static boolean find(String key)
    {
        String sqlQuery = "SELECT 公司名称,编号,帐户,员工数,注册时间,信息 FROM CompanyTable WHERE 编号='";
        sqlQuery+=key+"'";
        try {
            ResultSet rs = aStatement.executeQuery(sqlQuery);
            boolean c = rs.next();
            if(c)
                return true;
            else
                return false;
        } catch (SQLException ex) {
            System.out.println(ex.toString());
            return false;
        }
    }
    public static void addNew(Company aCompany)
    {
        name = aCompany.getName();
        id = aCompany.getId();
        account = aCompany.getAccount();
        num = aCompany.getNum();
        time = aCompany.getTime();
        info = aCompany.getInfo();
        //create the SQL insert statement using attribute values
        String sql = "insert into CompanyTable(公司名称,编号,帐户,员工数,注册时间,信息)VALUES('";
        sql+=name+"','";
        sql+=id+"','";
        sql+=account+"','";
        sql+=num+"','";
        sql+=time+"','";
        sql+=info+"')";

        boolean c = find(id);
        if(c == false)
        {
            try {
                int result = aStatement.executeUpdate(sql);
            }
            catch (SQLException ex) {
                System.err.println(ex.toString());
            }
        }

       else
       {
           System.exit(0);
       }

    }
    public static void update(Company aCompany)
{
    name = aCompany.getName();
    id = aCompany.getId();
    account = aCompany.getAccount();
    num = aCompany.getNum();
    time = aCompany.getTime();
    info = aCompany.getInfo();
    PreparedStatement ps = null;
    try {
        ps = aConnection.prepareStatement(
            "UPDATE CompanyTable set 公司名称=?,帐户=?,员工数=?,注册时间=?,信息=? WHERE 编号=?");
    } catch (SQLException ex) {
    }
    try {
        ps.setString(1,name);
        ps.setString(2,account);
        ps.setString(3,num);
        ps.setString(4,time);
        ps.setString(5,info);
        ps.setString(6,id);
        ps.executeUpdate();
    } catch (SQLException ex) {
        System.out.println(ex.toString());
        System.exit(0);
    }
     JOptionPane.showMessageDialog(null,"公司信息修改成功!");

}
    
    public static void delete(Company aCompnay)
    {
        id = aCompnay.getId();
        String sql = "DELETE FROM CompanyTable "+"WHERE 编号='"+id+"'";
        try {
            aStatement.executeUpdate(sql);
        } catch (SQLException ex) {
            System.out.println(ex.toString());
        }
    }
    public static void initialize()
    {
        try
        {
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            aConnection = DriverManager.getConnection(url,"","");
            aStatement = aConnection.createStatement();

        }
        catch(ClassNotFoundException e)
        { System.out.println(e);}
        catch(SQLException e)
        { System.out.println(e);}

    }
    public static void terminate()
    {
        try
        {
            aStatement.close();
            aConnection.close();
        }
        catch(SQLException e)
        { System.out.println(e);}
    }
    public static Vector getAll()
       {
           String sqlQuery = "SELECT 公司名称,编号,帐户,员工数,注册时间,信息 FROM CompanyTable";
           companys = new Vector();
           try
           {
               ResultSet rs = aStatement.executeQuery(sqlQuery);
               boolean moreData = rs.next();
               if(moreData)
                   while(moreData)
                   {
                       name = rs.getString(1);
                       id = rs.getString(2);
                       account = rs.getString(3);
                       num = rs.getString(4);
                       time = rs.getString(5);
                       info = rs.getString(6);
                       //create Company instance
                       aCompany = new Company(name,id,account,num,time,info);
                       companys.addElement(aCompany);
                       moreData = rs.next();
                   }
               rs.close();
           }
           catch(SQLException e)
           { System.out.println(e);}
           return companys;
    }
}