5.2 演示java代碼

package mysql;

import java.math.BigInteger;
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.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;

public class MySQLTest2 {

    public static long user_id;
    public static void main(String[] args) {

        MySQLTest2 mt=new MySQLTest2();

        /* 錄入用戶數據
        BigInteger user_id0 = new BigInteger("10001");
        Connection conn=mt.getConn("user_db");
        mt.insertUser(conn, bi, "tim--"+user_id0.longValue());
        */

        /* 錄入日志數據
        Connection conn2=mt.getConn("log_db");
        BigInteger user_id = new BigInteger("10001");
        BigInteger order_id = new BigInteger("20150531001");
        BigInteger orlog_id = new BigInteger("20150531001");
        mt.insertLog(conn2, user_id,order_id , orlog_id, "create a order for tim");
        */

        //錄入訂單數據
        Connection conn3=mt.getConn("order_db");
        BigInteger user_id2 = new BigInteger("10001");
        BigInteger order_id2 = new BigInteger("20150531001");
        BigInteger shop_id2 = new BigInteger("20150531001");
        mt.insertOrder(conn3,order_id2 , shop_id2, user_id2);



    }




    // 獲取數據庫的連接，如果擴展的話，可以單獨做一個接口提供給程序員來調用它
    // String type:連接的數據類型
    public Connection getConn(String type ) {
        String port="3307";
        if (type=="user_db" ){
             port="3307";
        }else if(type=="order_db"){
             port="3308";
        }else if(type=="log_db"){
             port="3309";
        }else if(type=="plocc_db") {
            port="3310";
        }else{
            port="3311";
        }

        Connection conn = null;
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        String url = "jdbc:mysql://192.168.52.130:"+port+"/"+type;
        try {
            conn = DriverManager.getConnection(url, "tim", "timgood2013");
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("the current db is :"+url);
        return conn;
    }

    // 獲取日期字符串
    public String getTimeByCalendar(){
        /*
        Calendar cal = Calendar.getInstance();
        int year = cal.get(Calendar.YEAR);//獲取年份
        int month=cal.get(Calendar.MONTH);//獲取月份
        int day=cal.get(Calendar.DATE);//獲取日
        int hour=cal.get(Calendar.HOUR);//小時
        int minute=cal.get(Calendar.MINUTE);//分           
        int second=cal.get(Calendar.SECOND);//秒
        String strdate=year+"-"+month+"-"+day+" "+hour+":"+minute+":"+second;
        */
        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//設置日期格式
        System.out.println(df.format(new Date()));// new Date()為獲取當前系統時間
        return df.format(new Date());
    }


    // 開始錄入用戶數據
    public int insertUser(Connection cnn,BigInteger user_id,String name){
        String sql="insert into user_db.uc_user(user_id,uc_name,created_time)values(?,?,?)";
        int i=0;  
        long uid = user_id.longValue();

        Connection conn=cnn;
        try{  
            PreparedStatement preStmt =conn.prepareStatement(sql);  
            preStmt.setLong(1, uid);
            preStmt.setString(2,name);
            preStmt.setString(3,getTimeByCalendar());

            i=preStmt.executeUpdate();  
        }  
        catch (SQLException e)  
        {  
            e.printStackTrace();  
        }  
        return i;//返回影響的行數，1為執行成功  

    }

    // 開始錄入日志數據
    public int insertLog(Connection cnn,BigInteger user_id,BigInteger order_id,BigInteger orlog_id,String action){
        String sql="insert into log_db.order_log(orlog_id,order_id,created_time,user_id,action)values(?,?,?,?,?)";
        int i=0;  

        Connection conn=cnn;
        try{  
            PreparedStatement preStmt =conn.prepareStatement(sql);  
            preStmt.setLong(1, user_id.longValue());
            preStmt.setLong(2, order_id.longValue());
            preStmt.setString(3,getTimeByCalendar());
            preStmt.setLong(4, orlog_id.longValue());
            preStmt.setString(5,action);            

            i=preStmt.executeUpdate();  
        }  
        catch (SQLException e)  
        {  
            e.printStackTrace();  
        }  
        return i;//返回影響的行數，1為執行成功  

    }


    // 開始錄入訂單數據
    public int insertOrder(Connection cnn,BigInteger order_id,BigInteger shop_id,BigInteger user_id){
        String sql="insert into order_db.order(order_id,shop_id,created_time,user_id)values(?,?,?,?)";
        int i=0;  

        Connection conn=cnn;
        try{  
            PreparedStatement preStmt =conn.prepareStatement(sql);  
            preStmt.setLong(1, order_id.longValue());
            preStmt.setLong(2, shop_id.longValue());
            preStmt.setString(3,getTimeByCalendar());
            preStmt.setLong(4, user_id.longValue());

            i=preStmt.executeUpdate();  
        }  
        catch (SQLException e)  
        {  
            e.printStackTrace();  
        }  
        return i;//返回影響的行數，1為執行成功  

    }   


    //開始錄入參數數據
    public int insertPlocc(){
        int i=0;
        return i;
    }
}