school.java

利用多线程从搜索引擎下载网页并提取数据到数据库。

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;

public class School {

	public int id; // primary_key

	public int person_id; // foreign key to people

	public String university;

	public String degree;

	public String major;

	public Date start_date;

	public Date end_date;

	public String activities;

	public int position;

	public Person person;

	private Connection cnn;
	public PreparedStatement ps;

	public School(Person person) {
		this.person = person;
		this.cnn = person.cnn;
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub

	}

	public static synchronized void insert(ArrayList<School> schools)
			throws SQLException {
		if (schools.size() == 0)
			return;
		School school1 = schools.get(0);
		school1.ps = school1.cnn
				.prepareStatement("insert into educational_destinations(person_id,university,degree,major,"
						+ "start_date,end_date,activities,position) select ?,?,?,?,?,?,?,?");

		for (School school : schools) {
			school.ps = school1.ps;
			school.insert();
		}
	}

	public static synchronized void printMe(ArrayList<School> schools) {

		for (School school : schools) {
			school.printMe();
		}
	}

	public void insert() throws SQLException {
		insertToDB();

	}

	private void printMe() {

		System.out.println(university);
		System.out.println(degree);
		System.out.println(major);
		System.out.println(start_date);
		System.out.println(end_date);
		System.out.println(activities);
		System.out.println(position);
	}

	public void insertToDB() throws SQLException {
		ps.setInt(1, person.id);
		ps.setString(2, university);
		ps.setString(3, degree);
		ps.setString(4, major);
		ps.setDate(5, start_date == null ? null : new java.sql.Date(start_date
				.getTime()));
		ps.setDate(6, end_date == null ? null : new java.sql.Date(end_date
				.getTime()));
		ps.setString(7, activities);
		ps.setInt(8, position);
		ps.execute();
	}

	public static synchronized void appendTo(ArrayList<School> schools,
			StringBuilder sb) {
		for (School school : schools) {
			sb.append("\r\n----------------------------\r\n");
			school.appendTo(sb);
		}
	}

	private void appendTo(StringBuilder sb) {
		sb.append(university);
		sb.append("\r\n");
		sb.append(degree);
		sb.append("\r\n");
		sb.append(major);
		sb.append("\r\n");
		sb.append(start_date);
		sb.append("\r\n");
		sb.append(end_date);
		sb.append("\r\n");
		sb.append(activities);
		sb.append("\r\n");
		sb.append(position);
		sb.append("\r\n");

	}
}