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();
}
}
}
相关推荐
SQL SERVER 导入 ORACLE 数据库 SQL SERVER 与 ORACLE 是两种不同的数据库管理系统,分别由 Microsoft 和 Oracle 公司开发。它们都具有强大的功能和广泛的应用,但是在实际应用中,经常需要将数据从一个数据库管理...
本文将详细介绍如何将 Oracle 数据库导入到 SqlServer 中。 Step 1-6: 数据源设置 首先,在要导入的数据库上右键,点击“任务”-“导入数据”。然后,在“导入导出向导”中点击“下一步”。接着,选择数据源为...
综上所述,SQL Server导入Oracle数据库是一项涉及多个技术层面的工作,包括数据抽取、转换、加载、验证以及性能和安全考虑。熟练掌握这些技能对于数据库管理员和IT专业人员来说至关重要,能够帮助他们在多平台环境中...
总之,从SQL Server导入Oracle数据库的过程涉及多个环节,包括数据导出、转换、导入、连接管理以及性能和安全性考虑。了解这些步骤并根据具体需求进行定制,是成功完成数据迁移的关键。在实际操作中,应根据项目规模...
"SQLServer数据库导入Oracle详解" 在数据库管理中,数据迁移是一个非常重要的步骤,特别是在不同数据库管理系统之间,例如从SQL Server到Oracle。下面我们将详细介绍如何将SQL Server数据库导入到Oracle中。 首先...
"Oracle数据库迁移到SQL Server" 本文将详细讲解如何使用Microsoft SQL Server Migration Assistant for Oracle.exe(微软数据库迁移工具)将Oracle数据库迁移到SQL Server。该工具可以帮助用户快速、安全地将...
标题与描述均指向了一个具体的技术操作过程:“SQLSERVER导入ORACLE数据库”。这涉及到跨数据库系统的数据迁移,是一项在企业级数据库管理中常见的需求,尤其是在不同的技术栈或业务整合时。以下将深入解析这一过程...
压缩包中的文件“SQLSERVER导入ORACLE数据库.pdf”很可能是详细的操作指南,它会涵盖上述步骤的具体实施细节。而“说明.txt”可能包含更具体的使用说明或注意事项。“教程阅读器下载.url”和“爱书吧 电子书 教程 让...
本教程将详细讲解如何将数据从SQL Server导入到Oracle数据库,确保你理解每一步骤,并能顺利进行操作。 首先,我们需要在SQL Server中创建一个新的数据库。这可以通过SQL Server Management Studio (SSMS) 来完成。...
本篇文章将详细讲解如何将数据从Oracle数据库导入到SQL Server 2008的步骤。 首先,我们来看第一步,配置数据源。在Windows操作系统中,可以通过控制面板的“管理工具”下的“数据源(ODBC)”来创建一个系统DNS,...
标题所述的"sqlserver2005移植到oracle数据库移植报告"主要涉及的是将SQL Server 2005中的数据迁移到Oracle数据库的过程和技术。在描述中提到了两种数据库之间的数据导入方法,以及针对Oracle运行环境的需求。接下来...
本文将详细解析一款名为“SqlServer批量导入Oracle小工具”的实用工具,它旨在帮助用户便捷地将Sql Server中的数据批量导入到Oracle数据库中,大大简化了跨平台数据迁移的过程。 首先,我们要理解Sql Server和...
String url = "jdbc:sqlserver://<服务器地址>:<端口>;databaseName=<数据库名>"; String user = "<用户名>"; String password = "<密码>"; try { Class.forName(...
本篇文章将详细探讨如何将ORACLE数据库中的BLOB(Binary Large Object)字段导入到SQL SERVER中的IMAGE字段,这通常涉及到数据转换、数据迁移以及可能的数据类型兼容性问题。 首先,让我们了解BLOB和IMAGE字段的...
在本项目中,开发者创建了一个基于Winform的C#应用程序,该程序实现了从SQL Server数据库向Oracle数据库的数据迁移功能,并且这个迁移过程是通过一个定时器来触发的,确保了数据的实时同步。以下是关于这个项目的...