首页 > 代码库 > JDBC远程从一个MySql数据库中的一张表里面读出数据（这个数据库需要用SSH隧道连接，大约8W条数据），然后分别插入到另一个数据库中的两张表里
JDBC远程从一个MySql数据库中的一张表里面读出数据（这个数据库需要用SSH隧道连接，大约8W条数据），然后分别插入到另一个数据库中的两张表里
package com.eeepay.lzj.db;import java.sql.Connection;import java.sql.Date;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import com.jcraft.jsch.JSch;import com.jcraft.jsch.Session;public class ChangeDB { public static int lport = 33102;//本地端口（随便取） public static String rhost = "172.***.***.***";//远程MySQL服务器 public static int rport = 3306;//远程MySQL服务端口 public static void go() { String user = "***";//SSH连接用户名 String password = "******";//SSH连接密码 String host = "120.132.***.***";//SSH服务器 int port = *****;//SSH访问端口 try { JSch jsch = new JSch(); Session session = jsch.getSession(user, host, port); session.setPassword(password); session.setConfig("StrictHostKeyChecking", "no"); session.connect(); System.out.println(session.getServerVersion());//这里打印SSH服务器版本信息 int assinged_port = session.setPortForwardingL(lport, rhost, rport); System.out.println("localhost:" + assinged_port + " -> " + rhost + ":" + rport); } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) { String mobileNo;//mobile_username String accountName;//account_name String accountNo;//account_no String cnaps;//cnaps_no String bankName;//bank_name String realName;//lawyer int status;//open_status String password;//mobile_password String idCard;//id_card_no int realNameAuth;//real_flag Date createTime; go(); try { //1、加载驱动 Class.forName("com.mysql.jdbc.Driver"); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } //2、创建连接 Connection conn = null; Connection conn2 = null; try { conn = DriverManager.getConnection("jdbc:mysql://localhost:33102/posp", "****", "***"); conn2 = DriverManager.getConnection("jdbc:mysql://115.29.***.***:3306/bag", "****", "*****"); } catch (SQLException e) { System.out.println("未连接上数据库"); e.printStackTrace(); } PreparedStatement pstmt = null; PreparedStatement pstmt2 = null; PreparedStatement pstmt22 = null; PreparedStatement pstmt3 = null; try { String sql = "select mobile_username,account_name,account_no,cnaps_no,bank_name,lawyer,open_status,mobile_password,id_card_no,real_flag,create_time from pos_merchant"; //String sql = "select * from settle_account where id=1"; String sql2 = "insert into bag_login(mobile_no,status,real_name,create_time,password,pay_password,idcard,real_name_auth) values(?,?,?,?,?,?,?,?)"; String sql22 = "select * from bag_login where mobile_no=?"; String sql3 = "insert into settle_account(mobile_no,account_name,account_no,cnaps,bank_name,create_time) values(?,?,?,?,?,?)"; pstmt = conn.prepareStatement(sql); pstmt2 = conn2.prepareStatement(sql2); pstmt22 = conn2.prepareStatement(sql22); pstmt3 = conn2.prepareStatement(sql3); ResultSet rs = pstmt.executeQuery(); int i=1; while(rs.next()){ System.out.println(i++); createTime = rs.getDate("create_time"); mobileNo = rs.getString("mobile_username"); accountName = rs.getString("account_name"); accountNo = rs.getString("account_no"); cnaps = rs.getString("cnaps_no"); bankName = rs.getString("bank_name"); realName = rs.getString("lawyer"); status = rs.getInt("open_status"); password = rs.getString("mobile_password"); idCard = rs.getString("id_card_no"); realNameAuth = rs.getInt("real_flag"); pstmt3.setString(1, mobileNo); pstmt3.setString(2, accountName); pstmt3.setString(3, accountNo); pstmt3.setString(4, cnaps); pstmt3.setString(5, bankName); pstmt3.setDate(6, createTime); pstmt3.execute(); pstmt22.setString(1, mobileNo); if(!pstmt22.execute()){ pstmt2.setString(1, mobileNo); pstmt2.setInt(2, status); pstmt2.setString(3, realName); pstmt2.setDate(4, createTime); pstmt2.setString(5, password); pstmt2.setString(6, password); pstmt2.setString(7, idCard); pstmt2.setInt(8, realNameAuth); pstmt2.execute(); } } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } finally{ try { pstmt.close(); conn.close(); pstmt2.close(); conn2.close(); pstmt3.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }}
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。