package com.hyzw.cczz.file.excel;
import java.net.ProxySelector;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
/**
* 从SQLSERVER数据库导入ORACLE数据库数据导入操作类 创建2个库连接,定义SQL语句
*
* @author LY
*
*/
public class DBUtils {
// private static Connection connection = null;
private Statement stmt = null;
private ResultSet rs = null;
/** Oracle数据库连接 URL */
private final static String DB_URL = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
/** Oracle数据库连接驱动 */
private final static String DB_DRIVER = "oracle.jdbc.driver.OracleDriver";
/** 数据库用户名 */
private final static String DB_USERNAME = "HNZZ";
/** 数据库密码 */
private final static String DB_PASSWORD = "11";
/** SQLSERVER数据库信息 **/
private final static String SQL_URL = "jdbc:microsoft:sqlserver://10.0.0.110:1433;DatabaseName=HNZZ";
private final static String SQL_DRIVER = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
private final static String SQL_USERNAME = "HNZZ";
private final static String SQL_PASSWORD = "11";
/** SQL QUERY DEFINE **/
private final static String sql_SourceOfStudent = "SELECT * FROM SourceOfStudent"; // 生源地信息表
private final static String sql_RegionCategories = "SELECT * FROM RegionCategories"; // 地区分类设置信息表
private final static String sql_MajorCategories = "SELECT * FROM MajorCategories"; // 专业分类信息表
private final static String sql_SchoolingLength = "SELECT * FROM SchoolingLength"; // 学制设置信息表
private final static String sql_MajorInfo = "SELECT * FROM MajorInfo"; // 专业设置信息表
private final static String sql_Group_info = "SELECT * FROM Group_info"; // 集团设置信息表
private final static String sql_SchoolCategory = "SELECT * FROM SchoolCategory"; // 学校分类信息表
private final static String sql_SchoolInfo = "SELECT * FROM SchoolInfo"; // 学校信息表
private final static String sql_DepartmentInfo = "SELECT * FROM DepartmentInfo"; // 院系信息表
private final static String sql_SchoolMajor_INFO = "SELECT * FROM SchoolMajor_INFO"; // 学校专业信息表
private final static String sql_Class_INFO = "SELECT * FROM Class_INFO"; // 班级信息表
private final static String sql_Section_INFO = "SELECT * FROM Section_INFO"; // 部门设置信息表
private final static String sql_CourseCategories = "SELECT * FROM CourseCategories"; // 课程类别设置表
private final static String sql_CourseInfo = "SELECT * FROM CourseInfo"; // 课程信息表
private final static String sql_Instrumenttation = "SELECT * FROM Instrumenttation"; // 仪器设备信息表
private final static String sql_BookMng = "SELECT * FROM BookMng"; // 图书管理表
private final static String sql_AdmissionTypeInfo = "SELECT * FROM AdmissionTypeInfo"; // 录取类别设置
private final static String sql_StudentTypeInfo = "SELECT * FROM StudentTypeInfo"; // 考生类别设置
private final static String sql_SchoolPlan = "SELECT * FROM SchoolPlan"; // 招生计划申报
private final static String sql_StudentInfo = "SELECT * FROM StudentInfo"; // 学生信息表
/** ORACLE SQL DEFINE **/
// 生源地信息表
private final static String SOURCEOFSTUDENT_ORCL = "INSERT INTO SOURCEOFSTUDENT(ID,SOURCEOFSTUDENTID,SOURCEOFSTUDENTNAME,CLASSIFICATION) VALUES(S_SOURCEOFSTUDENT.NEXTVAL,?,?,?)";
// 地区分类信息表
private final static String RegionCategories_ORCL = "INSERT INTO REGIONCATEGORY(ID,REGIONID,REGIONNAME,REGIONPROPERTIES,SUPERIORREGIONID,STATE,PARAM1,PARAM2,PARAM3,REMARK) VALUES(S_REGIONCATEGORY.NEXTVAL,?,?,?,?,?,?,?,?,?";
// 专业分类信息表
private final static String MAJORCATEGORIES_ORCL = "INSERT INTO MAJORCATEGORIES(ID,MAJORCATEGORIESID,MAJORCATEGORIESNAME,REMARK) VALUES(S_MAJORCATEGORIES.NEXTVAL,?,?,?)";
// 学制设置信息表
private final static String SCHOOLINGLENGTH_ORCL = "INSERT INTO SCHOOLINGLENGTH(ID,SCHOOLINGLENGTHID,SCHOOLINGLENGTHNAME) VALUES(S_SCHOOLINGLENGTH.NEXTVAL,?,?)";
// 专业设置信息表(FK SCHOOLINGLENGTHID,MAJORCATEGORIESID)
private final static String MAJORINFO_ORCL = "INSERT INTO MAJORINFO(ID,MAJORID,MAJORNAME,STATE_,REMARK) VALUES(S_MAJORINFO.NEXTVAL,?,?,?,?)";
// 集团设置信息表
private final static String GROUPINFORS_ORCL = "INSERT INTO GROUPINFORS(ID,GROUPID,GROUPNAME,INTRODUCTION,REMARK) VALUES(S_GROUPINFORS.NEXTVAL,?,?,?,?)";
// 学校分类信息表
private final static String SCHOOLCATEGORY_ORCL = "INSERT INTO SCHOOLCATEGORY(ID,SCHOOLCATEGORYID,SCHOOLCATEGORYNAME,PROPERTIES1,PROPERTIES2,PROPERTIES3,PARAM1,PARAM2,PARAM3,REMARK,STATE) VALUES(S_SCHOOLCATEGORY.NEXTVAL,?,?,?,?,?,?,?,?,?,?)";
// 学校信息表(FK SCHOOLCATEGORYID,EDUCATIONBUREAUID,GROUPID)
private final static String SCHOOLINFOR_ORCL = "INSERT INTO SCHOOLINFOR(ID,SCHOOLID,SCHOOLNAME,PHONE,WEBSITE,EMAIL,PRINCIPAL,INTRODUCTION,ADDRESS_,ZIPCODE,AREA,OWNAREA,LEASEAREA,BUILDINGAREA,DORMITORY,CANTEENS,OTHER,PHOTO,TEACHINGBUILDINGD,TEACHINGBUILDING,TEACHINGBUILDINGJ,DORMITORYD,DORMITORYJ,SCHOOLSYSTEM,SPONSOR,EXECUTIVEBRANCH,RESPONSIBLEPERSON,PARAM1,PARAM2,PARAM3,REMARK) VALUES(S_SCHOOLINFOR.NEXTVAL,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
// 院系信息表(FK SCHOOLID )
private final static String DEPARTMENTINFO_ORCL = "INSERT INTO DEPARTMENTINFO(ID,DEPARTMENTID,DEPARTMENTNAME,REMARK) VALUES(S_DEPARTMENTINFO.NEXTVAL,?,?,?)";
// 学校专业信息表(FK SCHOOLID,DEPARTMENTID,MAJORID全是外键)
private final static String SCHOOLMAJORINFO_ORCL = "INSERT INTO SCHOOLMAJORINFO(ID) VALUES(S_SCHOOLMAJORINFO.NEXTVAL)";
// 班级信息表(FK SCHOOLINGLENGTHID,SCHOOLID,DEPARTMENTID,MAJORID)
private final static String CLASSINFO_ORCL = "INSERT INTO CLASSINFO(ID,CLASSID,CLASSNAME,SCHOOLDATE,HEADTEACHER,PERSONNUMBER,REMARK) VALUES(S_CLASSINFO.NEXTVAL,?,?,?,?,?,?)";
// 部门信息设置表(FK SCHOOLID)
private final static String SECTIONINFO_ORCL = "INSERT INTO SECTIONINFO(ID,SECTIONID,SECTIONNAME,PERSONNUMBER,PRINCIPAL,PHONE,REMARK) VALUES(S_SECTIONINFO.NEXTVAL,?,?,?,?,?,?)";
// 课程类别设置表(FK SCHOOLID,MAJORID)
private final static String COURSECATEGORIES_ORCL = "INSERT INTO COURSECATEGORIES(ID,COURSECATEGORIESID,COURSECATEGORIESNAME,PROPERTIES) VALUES(S_COURSECATEGORIES.NEXTVAL,?,?,?)";
// 课程设置信息表(FK MAJORID,SchoolID,CourseCategoriesID)
private final static String COURSEINFO_ORCL = "INSERT INTO COURSEINFO(ID,COURSEID,COURSENAME,INTRODUCTION,CREDIT,CLASSHOUR,SEMESTER,REMARK) VALUES(S_COURSEINFO.NEXTVAL,?,?,?,?,?,?,?)";
// 仪器设备信息表(FK SCHOOLID)
private final static String INSTRUMENTTATION_ORCL = "INSERT INTO INSTRUMENTTATION(ID,INSTRUMENTTATIONID,INSTRUMENTTATIONNAME,INSTRUMENTTATIONVALUE,INSTRUMENTTATIONNUM,INSTRUMENTTATIONUNIT,INSTRUMENTTATIONBUYYEAR,TOTALVALUE,ANNUAL,ADDEDVALUE,REDUCEVALUE,REMARK) VALUES(S_INSTRUMENTTATION.NEXTVAL,?,?,?,?,?,?,?,?,?,?,?)";
// 图书管理信息表(FK SCHOOLID,MAJORCATEGORIESID)
private final static String BOOKMNG_ORCL = "INSERT INTO BOOKMNG(ID,BOOKID,BOOKNAME,BOOKVALUE,TOTALNUM,TOTALVALUE,ANNUAL,REMARK) VALUES(S_BOOKMNG.NEXTVAL,?,?,?,?,?,?,?)";
/** 中职招生管理系统 **/
// 录取类别设置
private final static String ADMISSIONTYPEINFO_ORCL = "INSERT INTO ADMISSIONTYPEINFO(ID,ADMISSIONTYPEID,ADMISSIONTYPENAME,REMARK) VALUES(S_ADMISSIONTYPEINFO.NEXTVAL,?,?,?)";
// 考生类别设置
private final static String STUDENTTYPEINFO_ORCL = "INSERT INTO STUDENTTYPEINFO(ID,STUDENTTYPEID,STUDENTTYPENAME,REMARK) VALUES(S_STUDENTTYPEINFO.NEXTVAL,?,?,?)";
// 招生计划申报(FK SCHOOLID)
private final static String SCHOOLPLAN_ORCL = "INSERT INTO SCHOOLPLAN(ID,PLANID,TOTALNUM,YEAR,PLANTYPE,REMARK) VALUES(S_SCHOOLPLAN.NEXTVAL,?,?,?,?,?)";
// 学生信息表(TypeID,ResidenceCity,ResidenceTown字段没有 FK
// MAJORID,SCHOOLINGLENGTHID,ADMISSIONID,CLASSID,SCHOOLID,COOPERATESCHOOLID,,SOURCEOFSTUDENTID)
private final static String STUDENTINFO_ORCL = "INSERT INTO STUDENTINFO(ID,STUDENTID,STUDENTNAME,ADMISSIONNUMBER,FORMERNAME,GENDER,NATION,IDENTIFICATION,BIRTHDAY,POLIC,RESIDENCETYPE,BIRTHPLACE,COMMUPHONE,EMAIL,GRADUATESCHOOL,RECRUITTYPE,SUBSIDYSTANDARD,BANKACCOUNT,GRADE,PHOTO,ENROLLMENTDATE,REMARK,COOPERATETYPE,RESIDENCEPRV,ADDRESS,ISDIBAO,ISGETHELP,SCHOOLTYPE,STUDENTTYPE,STUDENTNUM,POSTCODE,SJDZXJ,GATQ,HOMEPLACE,ISGRADUATES,DIPLOMAID,XUEJISTATUS,HAKCIKTYPEID,STUDYMODE,SHENGYUANTYPE,PARENTSNAME,TEACHINGSCHOOL,STUDENTMOBILE,GRADUATESCHOOLTYPE) VALUES(S_STUDENTINFO.NEXTVAL,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
/** 学生学籍管理系统 **/
/*** 系统管理系统 ****/
/**
* 获取SQLSERVER数据库连接
*/
public Connection getConnection() {
/** 声明Connection连接对象 */
Connection conn = null;
try {
/** 使用 Class.forName()方法自动创建这个驱动程序的实例且自动调用DriverManager来注册它 */
Class.forName(SQL_DRIVER);
/** 通过 DriverManager的getConnection()方法获取数据库连接 */
conn = DriverManager.getConnection(SQL_URL, SQL_USERNAME,
SQL_PASSWORD);
stmt = conn.createStatement();
} catch (Exception ex) {
ex.printStackTrace();
}
return conn;
}
/**
* 获取ORACLE数据库连接
*/
public Connection getORCLConnection() {
Connection conn = null;
try {
Class.forName(DB_DRIVER); // 加载ORACLE驱动
conn = DriverManager
.getConnection(DB_URL, DB_USERNAME, DB_PASSWORD); // 创建ORACLE连接
stmt = conn.createStatement(); // 创建状态集
} catch (Exception ee) {
ee.printStackTrace();
}
return conn;
}
/**
* 保存信息到ORACLE数据库
*/
public boolean saveToOracle(String SQL_ORCL, Connection connection) {
boolean boo = false;
if (SQL_ORCL == null || SQL_ORCL.length() == 0)
return boo;
try {
ProxySelector.setDefault(null);
stmt = connection.createStatement();
stmt.execute(SQL_ORCL);
return boo = true;
} catch (Exception e) {
e.printStackTrace();
return boo;
} finally {
try {
if (stmt != null) {
stmt.close();
}
} catch (Exception ee) {
ee.printStackTrace();
}
}
}
/**
* 查询数据部分
*/
public ResultSet executeQuery(String sqlStr, Connection connection) {
if (sqlStr == null || sqlStr.length() == 0)
return null;
try {
ProxySelector.setDefault(null);
stmt = connection.createStatement();
rs = stmt.executeQuery(sqlStr);
return rs;
} catch (SQLException ex) {
ex.printStackTrace();
return null;
}
}
/**
* 更新ORACLE数据部分
*/
public boolean executeUpdate(String ORCLStr, Connection connection) {
if (ORCLStr == null || ORCLStr.length() == 0)
return false;
try {
ProxySelector.setDefault(null);
stmt = connection.createStatement();
stmt.executeUpdate(ORCLStr);
return true;
} catch (SQLException ex) {
ex.printStackTrace();
return false;
}
}
/**
* 关闭状态集对象
*/
public void closeStmt() {
try {
if (stmt != null) {
stmt.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 关闭数据库连接
*/
public void closeConnection(Connection connection) {
try {
if (connection != null) {
/** 判断当前连接连接对象如果没有被关闭就调用关闭方法 */
if (!connection.isClosed()) {
connection.close();
}
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
/**
* SQLSERVER数据库表中数据插入到ORACLE数据库表中
*/
public static void main(String agrs[]) throws SQLException {
/** 学校信息管理数据库表查询集合 **/
Map<String, String> sql_Map = new HashMap<String, String>();
sql_Map.put("SourceOfStudent", sql_SourceOfStudent);
sql_Map.put("RegionCategories", sql_RegionCategories);
sql_Map.put("MajorCategories", sql_MajorCategories);
sql_Map.put("sql_SchoolingLength", sql_SchoolingLength);
sql_Map.put("sql_MajorInfo", sql_MajorInfo);
sql_Map.put("sql_Group_info", sql_Group_info);
sql_Map.put("sql_SchoolCategory", sql_SchoolCategory);
sql_Map.put("sql_SchoolInfo", sql_SchoolInfo);
sql_Map.put("sql_DepartmentInfo", sql_DepartmentInfo);
sql_Map.put("sql_SchoolMajor_INFO", sql_SchoolMajor_INFO);
sql_Map.put("sql_Class_INFO", sql_Class_INFO);
sql_Map.put("sql_Section_INFO", sql_Section_INFO);
sql_Map.put("sql_CourseCategories", sql_CourseCategories);
sql_Map.put("sql_CourseInfo", sql_CourseInfo);
sql_Map.put("sql_Instrumenttation", sql_Instrumenttation);
sql_Map.put("sql_BookMng", sql_BookMng);
sql_Map.put("sql_AdmissionTypeInfo", sql_AdmissionTypeInfo);
sql_Map.put("sql_StudentTypeInfo", sql_StudentTypeInfo);
sql_Map.put("sql_SchoolPlan", sql_SchoolPlan);
sql_Map.put("sql_StudentInfo", sql_StudentInfo);
DBUtils db = new DBUtils();
Connection connection_sql = db.getConnection();
Connection connection_orcl = db.getORCLConnection();
PreparedStatement pstmt = null;
try {
connection_orcl.setAutoCommit(false);// 事务提交设为手动提交
for (Iterator<String> iterator = sql_Map.keySet().iterator(); iterator
.hasNext();) {
String key = (String) iterator.next();
String query_sql = new String();
/**** 1 ****/
if (key.equals("SourceOfStudent")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(SOURCEOFSTUDENT_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("SourceOfStudentID"));
pstmt.setString(2, rs.getString("SourceOfStudentName"));
pstmt.setString(3, rs.getString("Classification"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/**** 2 ****/
if (key.equals("RegionCategories")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(RegionCategories_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("RegionID"));
pstmt.setString(2, rs.getString("RegionName"));
pstmt.setString(3, rs.getString("RegionProperties"));
pstmt.setString(4, rs.getString("SuperiorRegionID"));
pstmt.setString(5, rs.getString("State"));
pstmt.setString(6, rs.getString("Param1"));
pstmt.setString(7, rs.getString("Param2"));
pstmt.setString(8, rs.getString("Param3"));
pstmt.setString(9, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 3 ***/
if (key.equals("MajorCategories")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(MAJORCATEGORIES_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("MajorCategoriesID"));
pstmt.setString(2, rs.getString("MajorCategoriesName"));
pstmt.setString(3, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 4 ***/
if (key.equals("sql_SchoolingLength")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(SCHOOLINGLENGTH_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("SchoolingLengthID"));
pstmt.setString(2, rs.getString("SchoolingLengthName"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 5 ***/
if (key.equals("sql_MajorInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(MAJORINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("MajorID"));
pstmt.setString(2, rs.getString("MajorName"));
pstmt.setString(2, rs.getString("State"));
pstmt.setString(2, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 6 ***/
if (key.equals("sql_Group_info")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(GROUPINFORS_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("GroupID"));
pstmt.setString(2, rs.getString("GroupName"));
pstmt.setString(3, rs.getString("Introduction"));
pstmt.setString(4, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 7 ***/
if (key.equals("sql_SchoolCategory")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(SCHOOLCATEGORY_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("SchoolCategoryID"));
pstmt.setString(2, rs.getString("SchoolCategoryName"));
pstmt.setString(3, rs.getString("Properties1"));
pstmt.setString(4, rs.getString("Properties2"));
pstmt.setString(5, rs.getString("Properties3"));
pstmt.setString(6, rs.getString("Param1"));
pstmt.setString(7, rs.getString("Param2"));
pstmt.setString(8, rs.getString("Param3"));
pstmt.setString(9, rs.getString("Remark"));
pstmt.setString(10, "1");
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 8 ***/
if (key.equals("sql_SchoolInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(SCHOOLINFOR_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("SchoolID"));
pstmt.setString(2, rs.getString("SchoolName"));
pstmt.setString(3, rs.getString("Phone"));
pstmt.setString(4, rs.getString("Website"));
pstmt.setString(5, rs.getString("email"));
pstmt.setString(6, rs.getString("Principal"));
pstmt.setString(7, rs.getString("Introduction"));
pstmt.setString(8, rs.getString("Address"));
pstmt.setString(9, rs.getString("ZipCode"));
pstmt.setString(10, rs.getString("Area"));
pstmt.setString(11, rs.getString("OwnArea"));
pstmt.setString(12, rs.getString("LeaseArea"));
pstmt.setString(13, rs.getString("BuildingArea"));
pstmt.setString(14, rs.getString("Dormitory"));
pstmt.setString(15, rs.getString("Canteens"));
pstmt.setString(16, rs.getString("Other"));
pstmt.setString(17, rs.getString("Photo"));
pstmt.setString(18, rs.getString("TeachingBuildingD"));
pstmt.setString(19, rs.getString("TeachingBuilding"));
pstmt.setString(20, rs.getString("TeachingBuildingJ"));
pstmt.setString(21, rs.getString("DormitoryD"));
pstmt.setString(22, rs.getString("DormitoryJ"));
pstmt.setString(23, rs.getString("SchoolSystem"));
pstmt.setString(24, rs.getString("Sponsor"));
pstmt.setString(25, rs.getString("ExecutiveBranch"));
pstmt.setString(26, rs.getString("ResponsiblePerson"));
pstmt.setString(27, rs.getString("Param1"));
pstmt.setString(28, rs.getString("Param2"));
pstmt.setString(29, rs.getString("Param3"));
pstmt.setString(30, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 9 ***/
if (key.equals("sql_DepartmentInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(DEPARTMENTINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("DepartmentID"));
pstmt.setString(2, rs.getString("DepartmentName"));
pstmt.setString(3, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 10 ***/
if (key.equals("sql_SchoolMajor_INFO")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(SCHOOLMAJORINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 11 ***/
if (key.equals("sql_Class_INFO")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(CLASSINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("ClassID"));
pstmt.setString(2, rs.getString("ClassName"));
pstmt.setString(3, rs.getString("SchoolAge"));
pstmt.setString(4, rs.getString("HeadTeacher"));
pstmt.setString(5, rs.getString("PersonNum"));
pstmt.setString(6, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 12 ***/
if (key.equals("sql_Section_INFO")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(SECTIONINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("SectionID"));
pstmt.setString(2, rs.getString("SectionName"));
pstmt.setString(3, rs.getString("PersonNum"));
pstmt.setString(4, rs.getString("Principal"));
pstmt.setString(5, rs.getString("Phone"));
pstmt.setString(6, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 13 ***/
if (key.equals("sql_CourseCategories")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(COURSECATEGORIES_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("CourseCategoriesID"));
pstmt
.setString(2, rs
.getString("CourseCategoriesName"));
pstmt.setString(3, rs.getString("Properties"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 14 ***/
if (key.equals("sql_CourseInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(COURSEINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("CourseID"));
pstmt.setString(2, rs.getString("CourseName"));
pstmt.setString(3, rs.getString("Introduction"));
pstmt.setString(4, rs.getString("Credit"));
pstmt.setString(5, rs.getString("ClassHour"));
pstmt.setString(6, rs.getString("Semester"));
pstmt.setString(7, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 15 ***/
if (key.equals("sql_Instrumenttation")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(INSTRUMENTTATION_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("InstrumenttationID"));
pstmt
.setString(2, rs
.getString("InstrumenttationName"));
pstmt.setString(3, rs
.getString("InstrumenttationValue"));
pstmt.setString(4, rs.getString("InstrumenttationNum"));
pstmt
.setString(5, rs
.getString("InstrumenttationUnit"));
pstmt.setString(6, rs
.getString("InstrumenttationBuyYear"));
pstmt.setString(7, rs.getString("TotalValue"));
pstmt.setString(8, rs.getString("Annual"));
pstmt.setString(9, rs.getString("AddedValue"));
pstmt.setString(10, rs.getString("ReduceValue"));
pstmt.setString(11, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 16 ***/
if (key.equals("sql_BookMng")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(BOOKMNG_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("BookID"));
pstmt.setString(2, rs.getString("BookName"));
pstmt.setString(3, rs.getString("BookValue"));
pstmt.setString(4, rs.getString("TotalNum"));
pstmt.setString(5, rs.getString("TotalValue"));
pstmt.setString(6, rs.getString("Annual"));
pstmt.setString(7, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 17 ***/
if (key.equals("sql_AdmissionTypeInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(ADMISSIONTYPEINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("AdmissionID"));
pstmt.setString(2, rs.getString("AdmissionType"));
pstmt.setString(3, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 18 ***/
if (key.equals("sql_StudentTypeInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl
.prepareStatement(STUDENTTYPEINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("TypeID"));
pstmt.setString(2, rs.getString("TypeName"));
pstmt.setString(3, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 19 ***/
if (key.equals("sql_SchoolPlan")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(SCHOOLPLAN_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("PlanID"));
pstmt.setString(2, rs.getString("TotalNum"));
pstmt.setString(3, rs.getString("Year"));
pstmt.setString(4, rs.getString("PlanType"));
pstmt.setString(5, rs.getString("Remark"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
/*** 20 ***/
if (key.equals("sql_StudentInfo")) {
query_sql = sql_Map.get(key);
ResultSet rs = db.executeQuery(query_sql, connection_sql);
Long count = 0L;
pstmt = connection_orcl.prepareStatement(STUDENTINFO_ORCL);
while (rs.next()) {
count += 1;
pstmt.setString(1, rs.getString("StudentID"));
pstmt.setString(2, rs.getString("StudentName"));
pstmt.setString(3, rs.getString("AdmissionNumber"));
pstmt.setString(4, rs.getString("FormerName"));
pstmt.setString(5, rs.getString("Gender"));
pstmt.setString(6, rs.getString("Nation"));
pstmt.setString(7, rs.getString("Identification"));
pstmt.setString(8, rs.getString("BirthDay"));
pstmt.setString(9, rs.getString("Polic"));
pstmt.setString(10, rs.getString("ResidenceType"));
pstmt.setString(11, rs.getString("BirthPlace"));
pstmt.setString(12, rs.getString("CommuPhone"));
pstmt.setString(13, rs.getString("Email"));
pstmt.setString(14, rs.getString("GraduateSchool"));
pstmt.setString(15, rs.getString("RecruitType"));
pstmt.setString(16, rs.getString("SubsidyStandard"));
pstmt.setString(17, rs.getString("BankAccount"));
pstmt.setString(18, rs.getString("Grade"));
pstmt.setString(19, rs.getString("Photo"));
pstmt.setString(20, rs.getString("EnrollmentDate"));
pstmt.setString(21, rs.getString("Remark"));
pstmt.setString(22, rs.getString("CooperateType"));
pstmt.setString(23, rs.getString("ResidencePrv"));
pstmt.setString(24, rs.getString("Address"));
pstmt.setString(25, rs.getString("IsDiBao"));
pstmt.setString(26, rs.getString("IsGetHelp"));
pstmt.setString(27, rs.getString("SchoolType"));
pstmt.setString(28, rs.getString("StudentType"));
pstmt.setString(29, rs.getString("StudentNum"));
pstmt.setString(30, rs.getString("PostCode"));
pstmt.setString(31, rs.getString("SJDZXJ"));
pstmt.setString(32, rs.getString("GATQ"));
pstmt.setString(33, rs.getString("HomePlace"));
pstmt.setString(34, rs.getString("IsGraduates"));
pstmt.setString(35, rs.getString("DiplomaID"));
pstmt.setString(36, rs.getString("XueJiStatus"));
pstmt.setString(37, rs.getString("HakcikTypeID"));
pstmt.setString(38, rs.getString("StudyMode"));
pstmt.setString(39, rs.getString("ShengYuanType"));
pstmt.setString(40, rs.getString("ParentsName"));
pstmt.setString(41, rs.getString("TeachingSchool"));
pstmt.setString(42, rs.getString("StudentMobile"));
pstmt.setString(43, rs.getString("GraduateSchoolType"));
pstmt.addBatch();
}
pstmt.executeBatch();
System.out.println(key + "表共导入数据[" + count + "]条数据!");
}
}
} catch (SQLException e) {
try {
connection_orcl.rollback(); // 事物回滚
} catch (SQLException ee) {
ee.printStackTrace();
}
} finally {
connection_sql.commit();
pstmt.close();
connection_orcl.close();
connection_sql.close();
}
}
}
相关推荐
SQLSERVER导入ORACLE数据库.pdf
SQL Server导入Oracle数据库
SQLSERVER导入ORACLE数据库 PDF格式
SQLServer数据库导入Oracle
SQLSERVER导入ORACLE数据库
sql server导入oracle数据库.rar 介绍如何将sql server导入oracle数据库
Oracle数据库导入到SqlServer步骤(图文篇),自己写的,碰到不少问题,终于解决了。
sqlserver导入oracle数据库的数据,非常详细,对参数做了非常详细的说明
利用 Microsoft SQL Server Migration Assistant for Oracle.exe(微软数据库迁移工具) ,将oracle数据库迁移数据到SQL server详解。
sql server2005向oracle导入数据的方法
oracle数据库导入数据到sql server数据库操作步骤说明文档
SQLSERVER中利用dts将oracle数据库导入到SQLSERVER.pdf
SQLServer 数据导入到 Oracle1 数据库中。 资源中有操作详细过程,有详图!
数据库迁移指导SQL SERVER 2008向ORACLE 11G
方便数据迁移,从sql server导数据到oracle。