package com.espeed.text;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import com.mysql.jdbc.Connection;

public class JDBCTest {
	
	public static void initMailDetail() throws Exception{

		Connection localconn = getLocalConn();;
		PreparedStatement localpstmt = null;
		localconn.setAutoCommit(false);
		String sql="select uid,loginid,companydomain from yxy_user_info";
		localpstmt = (PreparedStatement)localconn.prepareStatement(sql);
		ResultSet rs = localpstmt.executeQuery();
		
		while (rs.next()){
			int uid = rs.getInt("uid");
			String loginid = rs.getString("loginid");
			String domain = rs.getString("companydomain");
			System.out.println(uid+","+loginid+","+domain);
			sql = "update yxy_send_mail_detail set loginid = ?,domain = ? where uid = ?";
			localpstmt = (PreparedStatement)localconn.prepareStatement(sql);
			localpstmt.setString(1, loginid);
			localpstmt.setString(2, domain);
			localpstmt.setInt(3, uid);
			localpstmt.executeUpdate();
			localconn.commit();
		}
	}

	public static void main(String[] args) throws Exception {
		initMailDetail();
	}
	
	public static Connection getLocalConn() {
	    String driver = "com.mysql.jdbc.Driver";
	    String url = "jdbc:mysql://14.152.95.22:33061/yxy_esmail?useUnicode=true&characterEncoding=utf8";
	    //String url = "jdbc:mysql://115.29.230.132:33061/webmailcopy1228?useUnicode=true&characterEncoding=utf8";
	    //String url = "jdbc:mysql://localhost:3306/yxybase?useUnicode=true&characterEncoding=utf8";
	    String username = "root";
	    String password = "sz1234567890";
	    Connection conn = null;
	    try {
	        Class.forName(driver);
	        conn = (Connection) DriverManager.getConnection(url, username, password);
	    }catch (Exception e) {
	        e.printStackTrace();
	    }
	    return conn;
	}
}