通用的DBUnit类
package java7.cshopping.DB;


import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

/**
*
* 数据库管理类， 封装了所有与数据库进行交换的方法 （封装完成）
* @author Administrator
*
*/
public class DB {
public static Connection getConn() {
Connection conn = null;
try {
Class.forName("com.mysql.jdbc.Driver");

conn = DriverManager

.getConnection("jdbc:mysql://192.168.3.219/shopping?"
+ "user=root&password=gxh&useUnicode=true&characterEncoding=gbk");

} catch (SQLException e) {
e.printStackTrace();
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
return conn;

}

public static PreparedStatement getPstmt (Connection conn, String sql){
PreparedStatement pstmt = null;

try {
if (conn != null) {
pstmt = conn.prepareStatement(sql);
}
} catch (SQLException e) {
e.printStackTrace();
}
return pstmt;
}

public static PreparedStatement getPstmt(Connection conn , String sql , int autoGeneratedKeys) {
PreparedStatement pstmt = null;

try {
if(conn != null) {
pstmt = conn.prepareStatement(sql, autoGeneratedKeys);
}
}catch (SQLException e) {
e.printStackTrace();
}
return pstmt;

}

public static Statement getStmt (Connection conn) {
Statement stmt = null;

try {
if(conn != null) {
stmt = conn.createStatement();
}
}catch(SQLException e) {
System.out.println("创建 stmt 失败！");
e.printStackTrace();
}
return stmt;
}

public static ResultSet getRs (Statement stmt ,String sql) {
ResultSet rs = null;

try{
if(stmt != null) {
rs = stmt.executeQuery(sql);
}
}catch(SQLException e) {
System.out.println("创建 rs 失败" + sql);
e.printStackTrace();
}
return rs;
}

public static void executeUpdata(Statement stmt ,String sql) {
try {
if(stmt != null) {
stmt.executeUpdate(sql);
}
}catch(SQLException e) {
e.printStackTrace();
}
}

public static void Close(Connection conn) {
try{
if(conn != null) {
conn.close();
conn = null;
}
}catch(SQLException e) {
e.printStackTrace();
}
}

public static void Close(Statement stmt) {
try {
if(stmt != null) {
stmt.close();
stmt = null;
}
}catch(SQLException e) {
e.printStackTrace();
}
}

public static void Close(ResultSet rs) {
try {
if(rs != null) {
rs.close();
rs = null;
}
}catch(SQLException e) {
e.printStackTrace();
}
}

}