java连接Mysql数据库的工具类

package myUtil;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

/**

* 链接mysql数据库

* @author weichk

*/

public class MysqlDbManager {

private static final String URL = "jdbc:mysql://127.0.0.1:3306/openfire";

private static final String USER = "root";

private static final String PASSWORD = "123456";

static {

try {

Class.forName("com.mysql.jdbc.Driver");

} catch (ClassNotFoundException e) {

System.out.println("加载Mysql数据库驱动失败！");

}

}

/**

* 获取Connection

*

* @return

* @throws SQLException

* @throws ClassNotFoundException

*/

public static Connection getConnection() throws SQLException {

Connection conn = null;

try {

conn = DriverManager.getConnection(URL,USERmssql数据库工具, PASSWORD);

} catch (SQLException e) {

System.out.println("获取数据库连接失败！");

throw e;

}

return conn;

}

/**

* 关闭ResultSet

* @param rs

*/

public static void closeResultSet(ResultSet rs) {

if (rs != null) {

try {

rs.close();

} catch (SQLException e) {

System.out.println(e.getMessage());

}

}

}

/**

* 关闭Statement

* @param stmt

*/

public static void closeStatement(Statement stmt) {

if (stmt != null) {

try {

stmt.close();

}

catch (Exception e) {

System.out.println(e.getMessage());

}

}

}

/**

* 关闭ResultSet、Statement

* @param rs

* @param stmt

*/

public static void closeStatement(ResultSet rs, Statement stmt) {

closeResultSet(rs);

closeStatement(stmt);

}

/**

* 关闭PreparedStatement

* @param pstmt

* @throws SQLException

*/

public static void fastcloseStmt(PreparedStatement pstmt) throws SQLException

{

pstmt.close();

}

/**

* 关闭ResultSet、PreparedStatement

* @param rs

* @param pstmt

* @throws SQLException

*/

public static void fastcloseStmt(ResultSet rs, PreparedStatement pstmt) throws SQLException

{

rs.close();

pstmt.close();

}

/**

* 关闭ResultSet、Statement、Connection

* @param rs

* @param stmt

* @param con

*/

public static void closeConnection(ResultSet rs, Statement stmt, Connection con) {

closeResultSet(rs);

closeStatement(stmt);

closeConnection(con);

}

/**

* 关闭Statement、Connection

* @param stmt

* @param con

*/

public static void closeConnection(Statement stmt, Connection con) {

closeStatement(stmt);

closeConnection(con);

}

/**

* 关闭Connection

* @param con

*/

public static void closeConnection(Connection con) {

if (con != null) {

try {

con.close();

}

catch (Exception e) {

System.out.println(e.getMessage());

}

}

}

}

（编辑：淮北站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!