package test;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.Statement;

public class InsertDB {

private static final String user = "sa";

private static final String pwd = "sa";

private static final String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=hhfly";

private static final String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";

public static Connection getCon() {

Connection con = null;

try {

Class.forName(driver).newInstance();

con = DriverManager.getConnection(url, user, pwd);

if (con != null) {

System.out.println("你已连接到数据库：" + con.getCatalog());

}

} catch (Exception e) {

System.out.println("连接数据库失败！");

e.printStackTrace();

}

return con;

}

public boolean insertDB(String FltNum, String FltLine, String FltDate,

String PsgName, String PsgType, String PsgSex, String PsgCab,

String PsgSeatNo, String PsgInfo) {

Connection con = null;

Statement stm = null;

boolean flag = false;

String sql = "insert into t_FltPsgInfo values('" + FltNum + "','"

+ FltLine + "','" + FltDate + "','" + PsgName + "','" + PsgType

+ "','" + PsgSex + "','" + PsgCab + "','" + PsgSeatNo + "','"

+ PsgInfo + "')";

try {

con = getCon();

stm = con.createStatement();

int i = stm.executeUpdate(sql);

if (i > 0) {

flag = true;

System.out.println(flag + "插入数据成功！");

}

} catch (Exception e) {

flag = false;

e.printStackTrace();

} finally {

close(null, stm, con);

}

return flag;

}

//关闭相关连接

public void close(ResultSet rs, Statement stm, Connection con) {

if (rs != null)

try {

rs.close();

} catch (Exception e) {

e.printStackTrace();

}

if (stm != null)

try {

stm.close();

} catch (Exception e) {

e.printStackTrace();

}

if (con != null)

try {

con.close();

} catch (Exception e) {

e.printStackTrace();

}

}

}

package test;

import java.io.RandomAccessFile;

import java.io.UnsupportedEncodingException;

public class DataGather {

private static final String path = "src/resource/test";

public static final String openFileStyle = "r";

public static final String fieldLimitChar = ",";

public static final int fieldAllCount = 9;

private int count;

private String FltNum;

private String FltLine;

private String FltDate;

private String PsgName;

private String PsgType;

private String PsgSex;

private String PsgCab;

private String PsgSeatNo;

private String PsgInfo;

/*

* 功能：解析文本文件

*/

public void loadFile() {

try {

RandomAccessFile raf = new RandomAccessFile(path, openFileStyle);

String line_record = raf.readLine();

while (line_record != null) {

// 解析每一条记录

parseRecord(line_record);

line_record = raf.readLine();

}

System.out.println("共有合法的记录" + count + "条");

} catch (Exception e) {

e.printStackTrace();

}

}

/*

* 功能：具体解析每一条记录，这里可以增加很多对记录的解析判断条件，如是否为字母、

* 数字、email等。

*/

private void parseRecord(String line_record) throws Exception {

//拆分记录

String[] fields = line_record.split(fieldLimitChar);

if (fields.length == fieldAllCount) {

FltNum = tranStr(fields[0]);

FltLine = tranStr(fields[1]);

FltDate = tranStr(fields[2]);

PsgName = tranStr(fields[3]);

PsgType = tranStr(fields[4]);

PsgSex = tranStr(fields[5]);

PsgCab = tranStr(fields[6]);

PsgSeatNo = tranStr(fields[7]);

PsgInfo = tranStr(fields[8]);

System.out.println(FltNum + " " + FltLine + " " + FltDate + " "

+ PsgName + " " + PsgType + " " + PsgSex + " " + PsgCab

+ " " + PsgSeatNo + " " + PsgInfo);

InsertDB db = new InsertDB();

db.insertDB(FltNum, FltLine, FltDate, PsgName, PsgType, PsgSex,

PsgCab, PsgSeatNo, PsgInfo);

count++;

}

}

private String tranStr(String oldstr) {

String newstr = "";

try {

newstr = new String(oldstr.getBytes("ISO-8859-1"), "GBK");

} catch (UnsupportedEncodingException e) {

e.printStackTrace();

}

return newstr;

}

}

package test;

public class Test {

public static void main(String[] args) {

try {

DataGather gather = new DataGather ();

gather.loadFile();

} catch (Exception e) {

e.printStackTrace();

}

}

}