mysql中文问题的解决

【 tulaoshi.com - 编程语言 】

/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package com.util;

import java.io.UnsupportedEncodingException;
import java.sql.*;

/**
*
* @author swing
*/
public class DbUtility {

    private Connection conn = null;
    private ResultSet set = null;
    private Statement st = null;
    // 数据库连接使用的参数；
    private String DBUrl = "jdbc:mysql://localhost/acctest？useUnicode=true&characterEncoding=gbk";
   //这里使用编码就可以解决mysql中文问题，其他得不需要设置
    private String DBUser = "root";// 用户名
    private String DBPass = "root";// 密码
    private String DBDriver = "org.gjt.mm.mysql.Driver";// mysql驱动
    public DbUtility() {

    }
    //获取数据库连接
    public Connection getAConnection(String DBDriver, String DBUrl, String DBUser, String DBPass) {
        try {
            Class.forName(DBDriver).newInstance();
        } catch (Exception e) {
            System.out.println("没有安装Mysql Java Connector或类路径未设置正确：   " + e);
            return null;
        }
        try {
            conn = DriverManager.getConnection(DBUrl, DBUser, DBPass);
        } catch (SQLException e) {
            System.out.println("com.util.DbUtility.getAConnection:数据库错误：   " + e);
            return null;
        }
        return conn;
    }
    //insert or update table
    public boolean execute(String sql) throws UnsupportedEncodingException {
        conn = getAConnection(DBDriver, DBUrl, DBUser, DBPass);
        if (conn == null) {
            System.out.println("连接数据库失败");
            return false;
        }
        try {
            st = conn.createStatement();
            st.execute(sql);
            st.close();
            conn.close();
            conn = null;

        } catch (SQLException e) {
            System.out.println("database error:" + e.getMessage());
            return false;

        }
        return true;
    }

    /**
     * Description : 执行查询语句
     *
     * @param sql
     *            sql查询语句
     * @return set ResultSet形式的查询结果,
     */
    public ResultSet query(String sql) {
        // 建立连接
        conn = getAConnection(DBDriver, DBUrl, DBUser, DBPass);
        if (conn == null) {
            System.out.println("连接数据库失败");
            return null;
        }
      
        try {
            st = conn.createStatement();
            return st.executeQuery(sql);

        } catch (SQLException e) {
            System.out.println("database error:" + e.getMessage());
            return null;
        }

    }

    /**
     * Description : 调用查询语句后关闭连接
     *
     * @return 1 成功关闭连接
     */
    public int close() {
        try {
            if (set != null) {
                set.close();
            }
            if (st != null) {
                st.close();
            }
            if (conn != null) {
                conn.close();
            }
            return 1;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
    }
}