经过几天的努力终于搞好了,这个类可以不用管数据库字段,不用写dao类,直接map添加,添加删除和修改,jdbc链接,分享给大家,用的话记得加上连接池,尊重原创,转载请注明
package jdbc;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;/**
* 操作数据库工具类
*
*
*/public class domain {
/**
* 连接数据
*
* @return conn
*/
public static Connection getConnection(String url, String username, String password) {
Connection conn = null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/" + url, username, password);
} catch (Exception e) {
e.printStackTrace();
} return conn;
} /**
* 关闭连接对象
*
* @param conn
* 连接对象
* @param pstmt
* 预编译对象
* @param rs
* 结果集
*/
public static void closeAll(Connection conn, PreparedStatement pstmt, ResultSet rs) {
try {
if (rs != null) {
rs.close();
}
if (pstmt != null) {
pstmt.close();
}
if (conn != null) {
conn.close();
}
} catch (Exception e) {
e.printStackTrace();
}
} /**
* 增删改操作
*
* @param sql
* SQL命令
* @param param
* 参数
* @return
*/
public static int executUpdate(Connection conn, String sql, Object[] param) {
int result = 0;
PreparedStatement pstmt = null;
try {
System.out.println(sql);
pstmt = conn.prepareStatement(sql);
if (param != null) {
for (int i = 0; i < param.length; i++) {
pstmt.setObject(i + 1, param[i]);
}
}
result = pstmt.executeUpdate();
} catch (Exception e) {
e.printStackTrace();
} finally {
closeAll(conn, pstmt, null);
} return result;
} /**
* 查询
*
* @return int
* @date 2015-7-25 上午11:10:06
*/
public static ResultSet executQuery(Connection conn, String sql, String[] param) {
PreparedStatement pstmt = null;
ResultSet result = null;
try {
pstmt = conn.prepareStatement(sql);
if (param != null) {
for (int i = 0; i < param.length; i++) {
pstmt.setString(i + 1, param[i]);
}
}
result = pstmt.executeQuery();
} catch (Exception e) {
e.printStackTrace();
} return result;
} /**
* 简单增删改SQL语句执行,复杂sql执行executUpdate方法
* 字符串类型需要加单引号
* @param url
* 数据库
* @param username
* 数据库用户名
* @param password
* 数据库密码
* @param map
* 参数列,值
* @param tableName
* 表名
* @param typeSql
* SQL类型 insert,dell,update
* @param oldLine
* 删除时为要删除的列名,更新的时候为where前的条件列名(仅当且使用dell和update时填写,insert时不作用)
* @param newLine
* 更新时where候的条件列名(仅当且使用update时填写,dell,insert时不作用)
* @param oldCondition
* 删除时为要删除的条件,更新的时候为where前的条件(仅当且使用dell和update时填写,insert时不作用)
* @param newCondition
* 更新的时候为where后的条件(仅当且使用update时填写,dell,insert时不作用)
*/
public static void sql(String url, String username, String password, Map map, String tableName,
String typeSql, String oldLine, String oldCondition, String newLine, String newCondition) {
String sql = "";
Connection conn = getConnection(url, username, password);
Object[] valueArray = null; if (typeSql.equals("insert")) {
List