📄 accesstojavadb.java
字号:
package org.wuhang.cjsjk.OldDbToNewDb;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Vector;
import javax.swing.JOptionPane;
import org.minjey.cjsjk.dao.DBConnection;
public class AccessToJavaDB extends Thread{
String d_path = null;
JProgressBarDemo progress = null;
HashMap<Integer,Integer> station_id_num,enrolltime_id_num,majorrecord_id_num,
majortype_id_num,majorlength_id_num,major_id_num,examtype_id_num,
studentstatue_id_num,student_id_num,studentcourse_id_num,studentmajor_id_num;
Vector<Integer> old_id_v = new Vector<Integer>();
Vector<Integer> course_id_num = new Vector<Integer>();
HashMap<Integer,Date> in_time_num = new HashMap<Integer,Date>();
HashMap<Integer,HashMap<Integer,Integer>> coursemajor_id_num = new HashMap<Integer,HashMap<Integer,Integer>>();
Connection new_con,old_con;
public AccessToJavaDB(){
}
public AccessToJavaDB(String db_path ,JProgressBarDemo progress){
this.d_path = db_path;
this.progress = progress;
this.start();
}
public void run() {
concert(d_path);
}
public void concert(String db_path){
new_con = DBConnection.getConnection();
old_con = null;
try {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
String url1 = "jdbc:odbc:driver={microsoft access driver (*.mdb)};dbq="+db_path+";pwd=12-343"; //��λ
old_con = DriverManager.getConnection(url1);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
//amdin表的导出/导入
TableAdminConcert.admin_concert(old_con);
//enrolltime表的导出/导入
TableEnrolltimeConcert.enrolltime_concert(old_con);
enrolltime_id_num = new HashMap<Integer,Integer>();
enrolltime_id_num = TableEnrolltimeConcert.getID_Num();
in_time_num = TableEnrolltimeConcert.getIntime();
//majorrecord表的导出/导入
TableMajorrecordConcert.majorrecord_concert(old_con);
majorrecord_id_num = new HashMap<Integer,Integer>();
majorrecord_id_num = TableMajorrecordConcert.getID_Num();
//majortype表的导出/导入
TableMajortypeConcert.majortype_concert(old_con);
majortype_id_num = new HashMap<Integer,Integer>();
majortype_id_num = TableMajortypeConcert.getID_Num();
//majorlength表的导出/导入
TableMajorlengthConcert.majorlength_concert(old_con);
majorlength_id_num = new HashMap<Integer,Integer>();
majorlength_id_num = TableMajorlengthConcert.getID_Num();
//station表的导出/导入
TableStationConcert.station_concert(old_con);
station_id_num = new HashMap<Integer,Integer>();
station_id_num = TableStationConcert.getID_Num();
old_id_v = TableStationConcert.getOld_id();
//major表的导出/导入
TableMajorConcert.major_concert(old_con,new_con,station_id_num,enrolltime_id_num,majorrecord_id_num,
majortype_id_num,majorlength_id_num,in_time_num);
major_id_num = new HashMap<Integer,Integer>();
major_id_num = TableMajorConcert.getID_Num();
//examtype表的导出/导入
TableExamtypeConcert.examtype_concert(old_con, new_con);
examtype_id_num = new HashMap<Integer,Integer>();
examtype_id_num = TableExamtypeConcert.getID_Num();
//course表的导出/导入
TableCourseConcert.course_concert(old_con, new_con, major_id_num);
course_id_num = TableCourseConcert.getCourse_id();
coursemajor_id_num = TableCourseConcert.getCourseMajor_id();
//studentstatue表的导出/导入
TableStudentStatueConcert.studentstatue_concert(new_con);
studentstatue_id_num = new HashMap<Integer,Integer>();
studentstatue_id_num = TableStudentStatueConcert.getID_Num();
//student表的导出/导入
TableStudentConcert.student_concert(old_con, new_con, major_id_num);
student_id_num = new HashMap<Integer,Integer>();
student_id_num = TableStudentConcert.getID_Num();
studentmajor_id_num = TableStudentConcert.getStudentMajor_id();
try {
new_con.commit();
DBConnection.closeConnecion();
new_con = DBConnection.getConnection();
} catch (SQLException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
//studentcourse表的导出/导入
TableStudentCourseConcert.studentcourse_concert(old_con, new_con,course_id_num,
student_id_num,coursemajor_id_num,studentmajor_id_num);
studentcourse_id_num = new HashMap<Integer,Integer>();
studentcourse_id_num = TableStudentCourseConcert.getID_Num();
try {
old_con.close();
new_con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
progress.setPBValue(100);
JOptionPane.showMessageDialog(null, "数据库转换成功!", "提示",
JOptionPane.PLAIN_MESSAGE);
}
/*
private void test(){
// DBConnection.closeConnecion();
new_con = DBConnection.getConnection();
try {
java.util.Date date =new java.util.Date();
String sql = "select * from studentstatue";
PreparedStatement st = new_con.prepareStatement(sql);
ResultSet rs = st.executeQuery();
while(rs.next()){
System.out.println(rs.getString("name"));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void main(String args[]){
new AccessToJavaDB().test();
}*/
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -