out.java

Java网络应用编程入门代码（朱喜福） 我觉得很好用

package myshop.db;

import java.io.BufferedWriter;
import java.io.FileWriter;
import java.io.IOException;
import java.io.BufferedReader;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.*;

public class Out {
//  private String filemae= "/c:/file.txt";
  private String filemae = "/c:/g1000.txt";
  public Out() {
  }

  private void in() {
    long l = System.currentTimeMillis();
    String[] s = new String[5];
    Connection conn = null;
    PreparedStatement ps = null;
    BufferedReader in = null;

    try {
      in = new BufferedReader(new FileReader(filemae));
      conn = ConnectionManager.getConnection();
      conn.setAutoCommit(false);
      ps = conn.prepareStatement(
          "insert into a (time,ua,mid,phone,serviceid) values (?,?,?,?,?)");
      for (String str; (str = in.readLine()) != null; ) {
        s = str.split("\t");

        for (int j = 1; j < s.length+1; j++) {
          ps.setString(j, s[j - 1]);
        }
//        ps.addBatch();
        ps.executeUpdate();
//        ps.close();
      }
      in.close();
      conn.commit();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        conn.close();
      } catch (SQLException ex1) {
        ex1.printStackTrace();
      }
    }
    System.out.println("use time:"+(System.currentTimeMillis()-l));
  }

  public static void processUpdateCounts(int[] updateCounts) {
        for (int i=0; i<updateCounts.length; i++) {
            if (updateCounts[i] >= 0) {
              System.out.println("1");
                // Successfully executed; the number represents number of affected rows
            } else if (updateCounts[i] == Statement.SUCCESS_NO_INFO) {
              System.out.print("2");
                // Successfully executed; number of affected rows not available
            } else if (updateCounts[i] == Statement.EXECUTE_FAILED) {
              System.out.print("3");
                // Failed to execute
            }
        }
    }


  private void out() {
    try {
      BufferedWriter out = new BufferedWriter(new FileWriter(filemae, true));
      for (int i = 0; i < 50000; i++) {
        out.write("31/Jan/2005:00:00:00 +0800");
        out.write("\t");
        out.write("Nokia6100");
        out.write("\t");
        out.write("00011111111111");
        out.write("\t");
        out.write("13800138000");
        out.write("\t");
        out.write("03201000");
        out.write("\r\n");
      }
      out.close();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

  public static void main(String[] args) {
    Out o = new Out();
    o.in();
  }
}