原文地址：https://www.cnblogs.com/FCWORLD/p/3401622.html

最近突然想到在上家公司封装的Mysql工具类没有保存一份，感觉比较可惜，在网上找了一下，找到一个不错的Mysql工具类封装，在这里记录一下，便于日后查阅。

1、数据库连接层MYSQL

/**
 * 数据库连接层MYSQL
 * @author Administrator
 *
 */
public class DBConnection {
    
    
    /**
     * 连接数据库
     * @return
     */
    public static Connection getDBConnection()
    {
        // 1. 注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        // 获取数据库的连接
        try {
            Connection conn  = java.sql.DriverManager.getConnection("jdbc:mysql://localhost/mysql?useUnicode=true&characterEncoding=utf-8", "root", "root");
            return conn;
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        return null;
    }
    
}

2、数据层封装

/**
 * MYSQL数据库底层封装
 * @author Administrator
 *
 */
public class DBManager {
    
    private PreparedStatement pstmt;
    private Connection conn;
    private ResultSet rs;
    

    /**
     * 打开数据库
     */
    public DBManager() {
        conn = DBConnection.getDBConnection();
    }
    
    /**
     * 执行修改添加操作
     * @param coulmn
     * @param type
     * @param sql
     * @return
     * @throws SQLException
     */
    public  boolean updateOrAdd(String[] coulmn, int[] type, String sql) throws SQLException
    {
        if(!setPstmtParam(coulmn, type, sql))
            return false;
        boolean flag = pstmt.executeUpdate()>0?true:false;
        closeDB();
        return flag;
    }
    /**
     * 获取查询结果集
     * @param coulmn
     * @param type
     * @param sql
     * @throws SQLException
     */
    public DataTable getResultData(String[] coulmn, int[] type, String sql) throws SQLException
    {
        DataTable dt = new DataTable();
        
        ArrayList<HashMap<String, String>>list = new ArrayList<HashMap<String, String>>();
        
        if(!setPstmtParam(coulmn, type, sql))
            return null;
        rs = pstmt.executeQuery();
        ResultSetMetaData rsmd = rs.getMetaData();//取数据库的列名 
        int numberOfColumns = rsmd.getColumnCount();
        while(rs.next())
        {
            HashMap<String, String> rsTree = new HashMap<String, String>(); 
            for(int r=1;r<numberOfColumns+1;r++)
             {
               rsTree.put(rsmd.getColumnName(r),rs.getObject(r).toString());
             }
            list.add(rsTree);
        }
        closeDB();
        dt.setDataTable(list);
        return dt;
    }
    
    /**
     * 参数设置
     * @param coulmn
     * @param type
     * @throws SQLException 
     * @throws NumberFormatException 
     */
    private boolean setPstmtParam(String[] coulmn, int[] type, String sql) throws NumberFormatException, SQLException
    {
        if(sql== null) return false;
        pstmt = conn.prepareStatement(sql);
        if(coulmn != null && type != null && coulmn.length !=0 && type.length !=0   )
        {        
            for (int i = 0; i<type.length; i++) {
                switch (type[i]) {
                case Types.INTEGER:
                    pstmt.setInt(i+1, Integer.parseInt(coulmn[i]));
                    break;
                case Types.BOOLEAN:
                    pstmt.setBoolean(i+1, Boolean.parseBoolean(coulmn[i]));
                    break;
                case Types.CHAR:
                    pstmt.setString(i+1, coulmn[i]);
                    break;
                case Types.DOUBLE:
                    pstmt.setDouble(i+1, Double.parseDouble(coulmn[i]));
                    break;
                case Types.FLOAT:
                    pstmt.setFloat(i+1, Float.parseFloat(coulmn[i]));
                    break;
                default:
                    break;
                }
            }
        }
        return true;
    }
    
    /**
     * 关闭数据库
     * @throws SQLException
     */
    private void closeDB() throws SQLException
    {
        if(rs != null)
        {
            rs.close();
        }
        if(pstmt != null)
        {
            pstmt.close();
        }
        if(conn != null)
        {
            conn.close();
        }
        
    }
}

3、数据集封装

/**
 * 数据集封装
 * @author Administrator
 */
public class DataTable {
    
    public String[] column;//列字段
    public String[][] row; //行值
    public int rowCount = 0;//行数
    public int colCoun = 0;//列数
    
    
    public DataTable() {
        super();
    }
    
    public DataTable(String[] column, String[][] row, int rowCount, int colCoun) {
        super();
        this.column = column;
        this.row = row;
        this.rowCount = rowCount;
        this.colCoun = colCoun;
    }


    public void setDataTable(ArrayList<HashMap<String, String>> list) {
        rowCount = list.size();
        colCoun = list.get(0).size();
        column = new String[colCoun];
        row = new String[rowCount][colCoun];
        for (int i = 0; i < rowCount; i++) {
            Set<Map.Entry<String, String>> set = list.get(i).entrySet();
            int j = 0;
            for (Iterator<Map.Entry<String, String>> it = set.iterator(); it
                    .hasNext();) {
                Map.Entry<String, String> entry = (Map.Entry<String, String>) it
                        .next();
                row[i][j] = entry.getValue();
                if (i == rowCount - 1) {
                    column[j] = entry.getKey();
                }
                j++;
            }
        }
    }

    public String[] getColumn() {
        return column;
    }

    public void setColumn(String[] column) {
        this.column = column;
    }

    public String[][] getRow() {
        return row;
    }

    public void setRow(String[][] row) {
        this.row = row;
    }

    public int getRowCount() {
        return rowCount;
    }

    public void setRowCount(int rowCount) {
        this.rowCount = rowCount;
    }

    public int getColCoun() {
        return colCoun;
    }

    public void setColCoun(int colCoun) {
        this.colCoun = colCoun;
    }
}

4、测试Demo 

/**
 * 测试Demo
 * @author Administrator
 */
public class TestBusIness{
    
    static String searchSql = "select * from score";
    static String insertSql = "insert into score(name, age, score)values(?,?,?)";
    static String deleteSql = "delete from score where id = ?";
    static String updateSql = "update score set name = ? where id = ?";
    
    public static void main(String[] args) {
        intsertData();
        searchData();
    }
    
    private static void intsertData()
    {    
        DBManager dm = new DBManager();
        String[] coulmn = new String[]{"wyf2",  "23", "89.5"};
        int[] type = new int[]{Types.CHAR, Types.INTEGER, Types.DOUBLE};
        
        try {
            boolean flag = dm.updateOrAdd(coulmn, type, insertSql);
            if(flag)
                System.out.println("插入成功");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    private static void searchData()
    {    
        DBManager dm = new DBManager();
        String[] coulmn = null;
        int[] type = null;
        
        try {
            DataTable dt = dm.getResultData(coulmn, type, searchSql);
            if(dt != null && dt.getRowCount()> 0){            
                for(int i = 0; i<dt.getRowCount(); i++)
                {
                    for(int j = 0; j<dt.getColCoun(); j++)
                    System.out.printf(dt.getRow()[i][j]+"\t");
                    System.out.println();
                }
            }
            else
                System.out.println("查询失败");
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

文章看着不错，总结比较全面，推荐给大家。

以前开发项目没用框架，直接面向对象开发很实用的一个mysql工具类。

<?php
header("content-type:text/html;charset=utf-8");
class DBUtils{
 
 
 /**
  *通用更新方法 insert update delete 操作
  *@param sql  
  *@return bool  true false
  */
  public function update($sql){
    $link = $this->getConn();
    mysql_query($sql);
    //如果出错显示
   if(DEBUG){
   echo mysql_error();
   }
    $rs = mysql_affected_rows($link);
    $rs = $rs > 0;
    mysql_close($link);
    return $rs;
  }
 
 /**
  *通用查询方法 select 操作
  *@param sql  
  *@return array
  */
  public function queryRows($sql){
   //创建连接，编码，数据库
   $link = $this->getConn();
   //发送sql
   $rs = mysql_query($sql);
   //如果出错显示
   if(DEBUG){
   echo mysql_error();
   }
   
   
   $rows = array();
   while($row = mysql_fetch_array($rs)){
    $rows[] = $row;//pdemo7.php
   }
   //
   mysql_free_result($rs);    
   mysql_close($link);
   return $rows;
  }
 
    
 /**
  *通用查询方法 select 操作  查询结果一行数据
  *@param sql  
  *@return array   如果失败返回 false;
  */
 public function queryRow($sql){
    $rs = $this->queryRows($sql);
    if(!empty($rs[0])){
     return $rs[0];
    }
    return false;
 }
 
 /**
  *通用查询方法 select 操作  查询结果一个数据
  *@param sql  
  *@return array   如果失败返回 false;
  * 例:  select count(*) from user;
  */
 public function queryObj($sql){
     $rs = $this->queryRows($sql);
    //var_dump($rs);
    if(!empty($rs[0][0])){
     return $rs[0][0];
    }
    return false;
 }
 

  private function getConn(){
   $link = mysql_connect('127.0.0.1','root','');
   mysql_query("set names utf8");
   mysql_select_db("news");
   return $link;
  }
 
}

mysql工具， 选来选去，还是官网的 mysql workbench吧，除了简单的连接查看之外，还有其他一些辅助工具，比如migration。

但是在安装utilities的时候，遇到了如下的问题，先记下。



为啥不用navicat来？ 

在deepinlinux下面显示有些乱码，查看可能是没有simsum.ttf这种字体，拷贝到相应的位置依然如此。肯呢个通过调整成英文可以解决吧，不过懒得弄了。

一、安装文件包下载
    相关MySQL的安装包和工具，可以免积分到CSDN下载栏目下载，地址为：http://download.csdn.net/detail/taomanman/9642852。

二、MySQL工具之SQLYog安装配置
1、下载以上链接文件，找到SQLyog-11.3.3-0.x64包，进行解压，如下图所示：

2、下载文件后，双击安装包，如下图所示：

3、安装语言，选择简体中文，如下图所示：

4、单击“下一步”，如下图所示：

5、选择“我接受许可证协议中的条款”，单击“下一步”，如下图所示：

6、单击“下一步”，如下图所示：

7、选择安装位置，单击“安装”，如下图所示：

8、安装过程如下图所示：

9、单击“下一步”，如下图所示：

10、直至安装完成，点击“完成”，如下图所示：

11、选择UI用户界面语言“简体中文”，如下图所示：

12、双击reg文件，添加到注册表，选择“是”，如下图所示：

13、成功添加到注册表，如下图所示：

14、再次运行SQLyog，如下图所示：

15、点击连接，如下图所示：

16、输入连接名称，如下图所示：

17、点击连接，如下图所示：
18、打开表，如下图所示: