java mysql

1.java操作mysql數據庫，首先加入lib包，我本地使用的是mysql-connector-java-5.1.18-bin.jar

以下java代碼例子：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/*
 * mysql數據庫操作
 * @@author
 * 創建時間：
 * 更新時間：
 * 
 */
public class DBhandle {
    
    private static String driver = "com.mysql.jdbc.Driver";
    private static String url = "jdbc:mysql://192.168.6.71:3306/";
    private static String db = "test";
    private static String character = "?useUnicode=true&characterEncoding=gbk";
    private static String user = "linchaojiang";
    private static String pass = "qwsSedcRFV";
     
    static Connection conn = null;
    static Statement statement = null;
    static PreparedStatement ps = null;
    static ResultSet rs = null;
    List<Map> list = new ArrayList<Map>();//返回所有記錄
    
    /*
     * 連接數據庫
     */    
     public static void connDB() {
          try {
           Class.forName(driver).newInstance();
           conn = DriverManager.getConnection(url+db+character, user, pass);
           if (!conn.isClosed()) {
            System.out.println("Succeeded connecting to MySQL!");
           }
           
           statement = conn.createStatement();
          } catch (Exception e) {
           e.printStackTrace();
          }
         }
        
    /*
     * 關閉數據庫
     */
     public static void closeDB() {         
          if(rs != null ){              
              try {
                rs.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }              
          }          
          if(statement != null){              
              try {
                statement.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
          }
          if(conn != null){
           try {
            conn.close();
            System.out.println("Database connection terminated!");
           } catch (SQLException e) {
            e.printStackTrace();
               }
           }
         }             
     
     /*
      * 查詢數據表
      */
     public List query(String sql){
        connDB();
        int count;
        try {
            rs = statement.executeQuery(sql);
            ResultSetMetaData rsmd;
            rsmd = rs.getMetaData();
            count = rsmd.getColumnCount();
            while(rs.next()){
                Map  map = new HashMap();
                for(int i=1;i<=count;i++){
                    //獲取指定列的表目錄名稱
                    String label=rsmd.getColumnLabel(i);
                    //以 Java 編程語言中 Object 的形式獲取此 ResultSet 對象的當前行中指定列的值
                    Object object= rs.getObject(i);
                    //把數據庫中的字段名和值對應為一個map對象中的一個鍵值對
                    map.put(label.toLowerCase(), object);
                }
                list.add(map);                                         
            }            
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally {
            closeDB();
        }      
        return list;         
     }
     
     /*
      * 數據插入
      */
     public void insert(String sql){
            connDB(); 
            try {
                statement.execute(sql);
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally {
                closeDB();
            }     
     }
     
     /*
      * 數據更新
      */
     public void update(String sql){         
         connDB();
         try {
             statement.execute(sql);
         } catch (SQLException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }finally {
             closeDB();
         }         
     } 
     
     /*
      * 數據刪除
      */
     public void delete(String sql){
         connDB();
         try {
             statement.execute(sql);
         } catch (SQLException e) {
             // TODO Auto-generated catch block
             e.printStackTrace();
         }finally {
             closeDB();
         }     
     }
}