前提：目前MySql資料庫中有兩個資料庫，名稱分別為：db01和db02。db01中的人員表叫t_user_info；db02中的人員表叫t_user。需求：將表t_user_info(id,name,type,content,createtime)的資料匯入到表t_use( userid,username,usertype, usercontent,user createtime)中。

第一步：運用JDBC建立資料來源

 /**

  * JDBC連線資料庫（db01） bgy

  * @return Connection

  */

     public static Connection getConnection01() throws

    {

       //第一步：載入MySQL的JDBC的驅動

       Class.forName("com.mysql.jdbc.Driver");

       //取得連線的url,能訪問MySQL資料庫的使用者名稱,密碼；db01：資料庫名

       String url = "jdbc:mysql://192.168.88.1:3306/db01";       

       String username = "bgy01";

       String password = "123456";

       //第二步：建立與MySQL資料庫的連線類的例項

       Connection con01 = (Connection) DriverManager.getConnection(url, username, password);       

       return con01;       

    }

    /**

     * JDBC連線資料庫（db02） bgy

     * @return Connection

     */

    public static Connection getConnection02() throws SQLException,java.lang.ClassNotFoundException

    {

       //第一步：載入MySQL的JDBC的驅動

       Class.forName("com.mysql.jdbc.Driver");

       //取得連線的url,能訪問MySQL資料庫的使用者名稱,密碼；db02：資料庫名

       String url = "jdbc:mysql://192.168.88.2:3306/db02";       

       String username = "bgy02";

       String password = "123456";

       //第二步：建立與MySQL資料庫的連線類的例項

       Connection con02 = (Connection) DriverManager.getConnection(url, username, password);       

       return con02;       

    }

第二步：同步資料實現詳細（方法dSynchronous()）

/**

     * 同步資料 bgy

     * @return String

     * @throws ClassNotFoundException

     * @throws SQLException

     */

    public String dSynchronous() throws SQLException, ClassNotFoundException

    {

       //前臺傳來值

       String param = request.getParameter("param");

       try

       {

           //設定“db01”資料來源

           Connection con01 = getConnection01();           

           Statement sql_statement01 = (Statement) con01.createStatement();

           //設定“db02”資料來源

           Connection con02 = getConnection02();           

           Statement sql_statement02 = (Statement) con02.createStatement();

           //人員資訊1

           if("1".equals(param))

           {

              //定位至db01

              sql_statement01.executeUpdate("use db01");

              //定位至db02

              sql_statement02.executeUpdate("use db02");

              //刪除“db02”使用者表t_user的資料

              String query1 = "TRUNCATE TABLE t_user;"; //TRUNCATE比DELETE效率高太多

              sql_statement02.executeUpdate(query1);

              String query2 = "ALTER TABLE t_user AUTO_INCREMENT=1;"; //自增序列設為1

              sql_statement02.executeUpdate(query2);

              //向“db02”使用者表t_user插入資料

              int tag = sql_statement02.executeUpdate("INSERT INTO db02.t_user (id, name,type,content,createtime) SELECT userid, username, usertype, usercontent, usercreatetime FROM db01.t_user_info");

                 String jsondata = null;

              if(tag > 0)

              {

                  jsondata = "{'flag':'ok'}";

              }

              else

              {

                  jsondata = "{'flag':'error'}";

              }

           }

           //“其餘”

           if("2".equals(param))

           {

              //業務邏輯程式碼

           }

           //“其餘”

           else

           {

              //業務邏輯程式碼

           }

           //關閉資料來源

           sql_statement01.close();

           conWly.close();

           sql_statement02.close();

           conYxl.close();

       }

       catch(java.lang.ClassNotFoundException e)

       {

            //載入JDBC錯誤,所要用的驅動沒有找到

            System.err.print("ClassNotFoundException");

            //其他錯誤

            System.err.println(e.getMessage());

       }

       catch(SQLException ex)

       {

           //顯示資料庫連線錯誤或查詢錯誤

           System.err.println("SQLException: " + ex.getMessage());

       }

       return SUCCESS;

    }