package com.mcong;import java.sql.*;
import java.util.HashMap;
import java.util.Map;
/**
 * Created by Smarter on 2017/12/6.
 */
public class BaseConnection {
public static Connection getConnection() {//用這個方法獲取mysql的連線
Connection conn = null;
 try {
            Class.forName("com.mysql.jdbc.Driver");//載入驅動類
 
conn = DriverManager.
                    getConnection("jdbc:mysql://host:port/dbname", "usrname", "pwd");//（url資料庫的IP地址，user資料庫使用者名稱，password資料庫密碼）
if (!conn.isClosed()) {
                System.out.println("connect success!");
}
        } catch (Exception e) {
            e.printStackTrace();
}
        return 
 
conn;
}

    /**
 * 增加資料，用不到~
 */
 /**
 * 刪除資料
 */
public static void deletedata(int index, int id)  //刪除資料函式
{
        Connection conn = getConnection();
 try {
            PreparedStatement psql; //還是用預處理
psql = conn.prepareStatement("delete from dbtable where id=?");
psql.setInt(index, id); //刪除id=111115774的值
 
psql.executeUpdate();
psql.close();
} catch (SQLException e) {
            e.printStackTrace();
} catch (Exception e) {
            e.printStackTrace();
} finally {
            System.out.println("資料庫資料刪除成功！" + "\n");
}
    }

    /**
 * 更新資料
 *
 * @param index1
* @param value1
* @param index2
* @param value2
* @throws SQLException
 */
public void updateData(int index1, String value1, int index2, String value2) throws SQLException {
        /**
 * 獲取資料庫連線
 */
Connection conn = getConnection();
String sqls = "update bizac set name=? where id=?";
PreparedStatement plsql = conn.prepareStatement(sqls);
plsql.setString(index1, value1);
plsql.setString(index2, value2);
// state.executeUpdate(sql); //將sql語句上傳至資料庫執行
plsql.executeUpdate();
plsql.close();
conn.close();//關閉通道
}

    /**
 * 查詢資料
 *
 * @param id
* @throws SQLException 只能查詢給定的引數，有需要增加的引數，寫在while迴圈裡，最後加到map集合，通過get取
 */
public void queryData(String id) throws SQLException {
        Connection conn = getConnection();
String querysqls = "select * from bizacct where id=?";
PreparedStatement plsql = conn.prepareStatement(querysqls);
plsql.setString(1, id);
// state.executeUpdate(sql); //將sql語句上傳至資料庫執行
ResultSet rs = plsql.executeQuery();
 while (rs.next()) {
            String ids = rs.getString("id");
String phone = rs.getString("phone");
String status = rs.getString("status");
String login = rs.getString("login");
String intercode = rs.getString("intercode");
String part_type = rs.getString("part_type");
String part_key = rs.getString("part_key");
Map<String, String> params = new HashMap<String, String>();
params.put("id", ids);
params.put("phone", phone);
params.put("status", status);
params.put("login", login);
params.put("intercode", intercode);
params.put("part_type", part_type);
params.put("part_key", part_key);
System.out.println("params ======= " + params);
System.out.println(params.get("id"));
}
        plsql.close();
conn.close();//關閉通道
}


    public static void main(String[] args) throws SQLException {
        BaseConnection baseConnection = new BaseConnection();
// 更新資料庫
// baseConnection.updateData(1,"zhangsanssss", 2,"16286547");
// 查詢資料庫
baseConnection.queryData("16286547");
// 刪除資料
// BaseConnection.deletedata(1,111115774);
}
}