tablestudentcourseconcert.java

一个可以存储和打印成绩单的系统

package org.wuhang.cjsjk.OldDbToNewDb;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Vector;
public class TableStudentCourseConcert {
	static HashMap<Integer,Integer> id_num = new HashMap<Integer,Integer>();
	public static HashMap<Integer,Integer> getID_Num(){
		return id_num;
	}
	public static void studentcourse_concert(Connection old_con,Connection new_con,
			Vector<Integer> course_id_num,
			HashMap<Integer,Integer> student_id_num,
			HashMap<Integer,HashMap<Integer,Integer>> coursemajor_id_num,
			HashMap<Integer,Integer> studentmajor_id_num) {
		int count = 0;
		String sql = null;
		try {
			Statement st = old_con.createStatement();
			ResultSet rs = st.executeQuery("select * from student_course order by id");
			
			Vector<Integer> student_id = new Vector<Integer>();
			Vector<Integer> course_id = new Vector<Integer>();
			Vector<String> grade = new Vector<String>();
			int old_student_id = 0;
			int old_course_id = 0;
			int new_student_id = 0;
			int new_course_id = 0;
			int student_major_id = 0;
			HashMap<Integer,Integer> majorcourse_id = null;
			
			while (rs.next()) {
				count++;
				int old_id = rs.getInt("id");
				old_student_id = rs.getInt("student_id");
				old_course_id = rs.getInt("course_id");
				if(student_id_num.containsKey(old_student_id) && course_id_num.contains(old_course_id)){
					new_student_id = student_id_num.get(old_student_id);
					
					student_major_id = studentmajor_id_num.get(new_student_id);
					majorcourse_id = new HashMap<Integer,Integer>();
					majorcourse_id = coursemajor_id_num.get(old_course_id);
					if (majorcourse_id.containsKey(student_major_id)) {
						new_course_id = majorcourse_id.get(student_major_id);
						student_id.addElement(new_student_id);
					    course_id.addElement(new_course_id);
						grade.addElement(rs.getString("grade"));
						id_num.put(old_id, count);
                   }
				}
			}
			rs.close();
			st.close();
			System.out.println("==================================");
			sql = "insert into studentcourse (student_id,course_id,grade) values (?,?,?)";
			PreparedStatement sstt = new_con.prepareStatement(sql);
		    for (int i = 0; i<student_id.size(); i++) {
				sstt.setInt(1, student_id.elementAt(i));
				sstt.setInt(2, course_id.elementAt(i));
				sstt.setString(3, grade.elementAt(i));
				sstt.execute();
				if((i%1000)==0)
					System.out.println(i+"  ");
			}
			sstt.close();
			new_con.commit();
		} catch (Exception e) {
			System.out.println("some error");
			System.out.println(sql+"\n"+e.getMessage());
        }
	}
}