Java编程

开发平台：
Java

Database.java~94~：源码内容
							package manpowersystem;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2003</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
import java.sql.*;
import java.util.*;
public class Database {
    Connection conn = null;
    ResultSet rs = null;
    Statement stmt = null;
    public RecordItem[] AccessData() throws Exception {
        Class.forName( "com.microsoft.jdbc.sqlserver.SQLServerDriver" );
        String url = "jdbc:microsoft:sqlserver://localhost:1433;" +
            "DatabaseName=Manpower";
        conn = DriverManager.getConnection( url, "sa", "" );
        stmt = conn.createStatement( ResultSet.TYPE_SCROLL_SENSITIVE,
                                     ResultSet.CONCUR_UPDATABLE );
        String SQL = "select * from WorkTime";
        rs = stmt.executeQuery( SQL );
        RecordItem[] item = new RecordItem[ 100 ];
        for ( int j = 0; j < 100; j++ )
            item[ j ] = new RecordItem();
        int i = 0;
        while ( rs.next() && ( i < 100 ) ) {
            item[ i ].SetEmployeeID( rs.getString( "EmployeeID" ) );
            item[ i ].SetEmployeeName( rs.getString( "EmployeeName" ) );
            item[ i ].SetOnWorkTime(rs.getString( "OnworkTime" ) );
            item[ i ].SetOffworkItem( rs.getString( "OffworkTime" ) );
            item[ i ].SetEmployeeID( rs.getString( "LeaveworkTime" ) );
            item[ i ].SetEmployeeID( rs.getString( "Describe" ) );
            i++;
        }
        RecordItem[] result = new RecordItem[ i ];
        for ( int j = 0; j < i; j++ ) {
            result[ j ] = new RecordItem();
            result[ j ] = item[ j ];
        }
        rs.close();
        stmt.close();
        conn.close();
        return result;
    }
    public void StoreData( RecordItem item ) throws Exception {
        Class.forName( "com.microsoft.jdbc.sqlserver.SQLServerDriver" );
        String url = "jdbc:microsoft:sqlserver://localhost:1433;" +
            "DatabaseName=Manpower";
        conn = DriverManager.getConnection( url, "sa", "" );
        stmt = conn.createStatement( ResultSet.TYPE_SCROLL_SENSITIVE,
                                     ResultSet.CONCUR_UPDATABLE );
        String SQL = "select * from WorkTime where EmployeeID = '" +
            item.GetEmployeeID() + "'";
        rs = stmt.executeQuery( SQL ); //查找是否存在该员工的记录
        //如果已经存在该员工的记录则更新，如果不存在则插入新的记录
        if ( rs.next() ) {
            SQL = "update WorkTime set EmployeeName='" + item.GetEmployeeName() +
                "',"
                + " OnworkTime='" + item.GetOnrWorkTime() + "',"
                + " Describe='" + item.GetDescribe() + "'"
                + " where EmployeeID = '" + item.GetEmployeeID() + "'";
            stmt.execute( SQL );
        }
        else {
            SQL =
                "insert WorkTime(EmployeeID,EmployeeName,OnworkTime, Describe) "
                + " values('" + item.GetEmployeeID() + "', '" +
                item.GetEmployeeName()
                + "','" + item.GetOnrWorkTime() + "','" + item.GetDescribe() +
                "')";
            stmt.execute( SQL );
        }
        rs.close();
        stmt.close();
        conn.close();
    }
    //删除相应工号的员工记录
    public void DeleteData( String strEmployeeID ) throws Exception {
        Class.forName( "com.microsoft.jdbc.sqlserver.SQLServerDriver" );
        String url = "jdbc:microsoft:sqlserver://localhost:1433;" +
            "DatabaseName=Manpower";
        conn = DriverManager.getConnection( url, "sa", "" );
        stmt = conn.createStatement( ResultSet.TYPE_SCROLL_SENSITIVE,
                                     ResultSet.CONCUR_UPDATABLE );
        String SQL = "delete from WorkTime where EmployeeID='" + strEmployeeID +
            "'";
        stmt.execute( SQL ); //查找是否存在该员工的记录
    }
}

						