SQL是Structured Query Language(结构化查询语言)的缩写。SQL是专为数据库而建立的操作命令集，是一种功能齐全的数据库语言。在使用它时，只需要发出“做什么”的命令，“怎么做”是不用使用者考虑的。SQL功能强大、简单易学、使用方便，已经成为了数据库操作的基础，并且现在几乎所有的数据库均支持SQL。
经过几天的努力终于搞好了，这个类可以不用管数据库字段，不用写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.divpareStatement(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.divpareStatement(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<String, Object> 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<Object> key = new ArrayList<Object>();
List<Object> value = new ArrayList<Object>();
StringBuffer sb = new StringBuffer();
StringBuffer wen = new StringBuffer(); for (Object string : map.keySet()) {
key.add(string);
value.add(map.get(string));
}
Object[] keyArray = key.toArray();
valueArray = value.toArray(); for (int i = 0; i < keyArray.length; i++) {
sb.append(keyArray[i] + ",");
wen.append("?,");
}
String string = sb.toString();
string = string.substring(0, string.length() - 1);
String wenStr = wen.toString();
wenStr = wenStr.substring(0, wenStr.length() - 1);
sql = "INSERT INTO " + tableName + "(" + string + ") VALUES (" + wenStr + ")";
} else if (typeSql.equals("dell")) {
sql = "DELETE FROM " + tableName + " WHERE " + oldLine + " = " + oldCondition;
} else if (typeSql.equals("update")) {
sql = "UPDATE " + tableName + " SET " + oldLine + "= " + oldCondition + " WHERE " + newLine + " = "
+ newCondition;
} int executUpdate = executUpdate(conn, sql + ";", valueArray);
System.out.println(executUpdate);
}//测试
public static void main(String[] args) {
Map<String, Object> map = new HashMap<String, Object>();
map.put("appid", "lisi"); for (int i = 0; i < 100; i++) {
System.out.println(i);
map.put("id",i); // 增加
sql("test", "root", "", map, "user", "insert", "", "", "", ""); // 删除
sql("test", "root", "", map, "user", "dell", "id", i+"","", ""); // 修改//
sql("test", "root", "", map, "user", "update", "appid", "'zhang'", "id", "0");
} // map.put("password", "123");
}
} 以上就是数据库jdbc封装的详细内容，更多请关注php中文网其它相关文章！
学习教程快速掌握从入门到精通的SQL知识。
|