Java编程

开发平台：

Java

IPInfoToDB.java~44~：源码内容

							package tsinghuaip;
import java.sql.*;
import java.util.*;
import java.io.*;
public class IPInfoToDB {
    private String strTxtFileName; //IP地址文本文件名
    private Connection conn = null;
    private ResultSet rs = null;
    private Statement stmt = null;
    public IPInfoToDB() {
        strTxtFileName = new String();
    }
    //设置文本文件名
    public void SetTxtFileName(String strFileName) {
        strTxtFileName = strFileName;
    }
    public void SaveIPToDB() throws Exception {
        String strSeparator = "|"; //the separator of the text file field
        String strTmp = "";
        //进行数据库得连接
        Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
        String url = "jdbc:microsoft:sqlserver://localhost:1433;" +
            "DatabaseName=CampusIP";
        conn = DriverManager.getConnection(url, "sa", "");
        stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                    ResultSet.CONCUR_UPDATABLE);
        //从文本文件中读取数据
        BufferedReader inTxt = new BufferedReader(new FileReader(
            strTxtFileName));
        while ( (strTmp = inTxt.readLine()) != null) {
            StringTokenizer strToken = new StringTokenizer(strTmp, "|");
            String arrTmp[];
            arrTmp = new String[3];
            for (int i = 0; i < 3; i++)
                arrTmp[i] = new String("");
            int index = 0;
            while (strToken.hasMoreElements()) {
                strTmp = (String) strToken.nextElement();
                strTmp = strTmp.trim();
                arrTmp[index++] = strTmp;
            }
            //下面就是将这些数据写进数据库
            SQL =
                "insert IPInfo(STARTIP,ENDIP,LOCAL) "
                + " values('" + item.GetEmployeeID() + "', '"
                + item.GetEmployeeName() + "','"
                + item.GetOnWorkTime() + "','"
                + item.GetOffWorkTime() + "','"
                + item.GetLeaveWorkTime() + "','"
                + item.GetDescribe() + "')";
            stmt.execute(SQL);
        }
        rs.close();
        stmt.close();
        conn.close();
    }
}

						