502647092/Yum
1
0
Fork 0
mirror of https://e.coding.net/circlecloud/Yum.git synced 2024-12-23 05:08:47 +00:00
Code Issues Projects Releases Wiki Activity

remove sql and FileUtils...

Browse Source 
Signed-off-by: 502647092 <jtb1@163.com>
This commit is contained in:
502647092 2015-09-07 20:54:21 +08:00
parent 85d0bdf85e
commit 3a539f593f
4 changed files with 0 additions and 538 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/main/java/cn/citycraft/Yum/sql/MySQLHelper.java
View File

@ -1,36 +0,0 @@
package cn.citycraft.Yum.sql;
// import java.sql.*;
/**
* 数据库操作类
*
* @author 蒋天蓓 2015年7月14日下午3:25:06
*/
public class MySQLHelper extends SQLHelper {
private static String drivername = "com.mysql.jdbc.Driver";
/**
* 初始化连接信息
*
* @param host
* - 域名
* @param port
* - 端口
* @param dbname
* - 数据库
* @param username
* - 用户名
* @param password
* - 密码
*/
public MySQLHelper(String host, String port, String dbname, String username, String password) {
super(password, password, drivername, getUrl(host, port, dbname));
}
public static String getUrl(String host, String port, String dbaName) {
String Encode = "?&useUnicode=true&characterEncoding=utf-8";
return "jdbc:mysql://" + host + ":" + port + "/" + dbaName + Encode;
}
}

416
src/main/java/cn/citycraft/Yum/sql/SQLHelper.java
View File

@ -1,416 +0,0 @@
package cn.citycraft.Yum.sql;
/*
* 数据库连接、选择、更新、删除演示
*/
// import java.sql.*;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
/**
* @author 蒋天蓓 2015年7月14日下午3:25:06 数据库操作类
*/
public abstract class SQLHelper {
// ///////////////////////////////////////———–>>>数据成员 and 构造函数
protected Connection dbconn = null;
protected Statement dbstate = null;
protected ResultSet dbresult = null;
protected String username;
protected String password;
protected String url;
protected String drivername;
/**
* 初始化连接信息
*
* @param username
* - 用户名
* @param password
* - 密码
* @param drivername
* - 驱动名称
* @param url
* - 数据库地址
*/
public SQLHelper(String username, String password, String drivername, String url) {
try {
Class.forName(drivername).newInstance();
} catch (Exception e) {
}
this.username = username;
this.password = password;
this.drivername = drivername;
this.url = url;
}
/**
* 创建数据表
*
* @param tableName
* - 表名
* @param fields
* - 字段参数
* @param Conditions
* -附加值
* @return 运行结果
*/
public boolean createTables(String tableName, HashMap<String, String> fields, String Conditions) {
if (!dbConnection())
return false;
String kv = "";
for (Entry<String, String> kvs : fields.entrySet())
kv += "`" + kvs.getKey() + "` " + kvs.getValue() + " NOT NULL , ";
kv = kv.substring(0, kv.length() - 2);// 根据String的索引提取子串
String sql = "CREATE TABLE `" + tableName + "` ( " + kv + (Conditions == "" ? "" : " , " + Conditions) + " ) ENGINE = InnoDB DEFAULT CHARSET=UTF8";
try {
PreparedStatement state = dbconn.prepareStatement(sql);
state.executeUpdate();
state.close();
return true;
} catch (final Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
}
return false;
}
/**
* 断开数据库
*
* @return bool值，成功返回true，失败返回false
*/
public boolean dbClose() {
try {
dbconn.close();
return true;
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
return false;
}
}// end dbClose()
/**
* 连接到数据库
*
* @return 是否成功
*/
public boolean dbConnection() {
try {
dbconn = DriverManager.getConnection(url, username, password);
dbstate = dbconn.createStatement();
return true;
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());// 得到出错信息
print("登录URL: " + url); // 发生错误时，将连接数据库信息打印出来
print("登录账户: " + username);
print("登录密码: " + password);
return false;
}
}
/**
* 对数据库表中的记录进行删除操作
*
* @param tableName
* @param condition
* @return bool值，表示删除成功或者失败。
*/
public boolean dbDelete(String tableName, HashMap<String, String> selConditions) {// ——–>>>删除操作
if (!dbConnection())
return false;
String selCondition = "";
if (selConditions != null && !selConditions.isEmpty()) {
for (Entry<String, String> kvs : selConditions.entrySet())
selCondition += kvs.getKey() + "='" + kvs.getValue() + "', ";
selCondition = " WHERE " + selCondition.substring(0, selCondition.length() - 2);// 根据String的索引提取子串
}
String sql = "DELETE FROM `" + tableName + "` " + selCondition;
try {
dbstate.executeUpdate(sql);
return true;
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
return false;
}
}// end dbDelete(…)
/**
* 判断数据库某个值是否存在!
*
* @param tableName
* 数据库表名
* @param fieles
* 字段名
* @param selCondition
* 选择条件
* @return 首个符合条件的结果
*/
public boolean dbExist(String tableName, HashMap<String, String> selConditions) {
if (!dbConnection())
return false;
String selCondition = "";
if (selConditions != null && !selConditions.isEmpty()) {
for (Entry<String, String> kvs : selConditions.entrySet())
selCondition += kvs.getKey() + "='" + kvs.getValue() + "', ";
selCondition = " WHERE " + selCondition.substring(0, selCondition.length() - 2);// 根据String的索引提取子串
}
String sql = "SELECT * FROM " + tableName + selCondition;
try {
dbresult = dbstate.executeQuery(sql);
return dbresult.next();
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
}
return false;
}
/**
* 对数据库表进行插入操作
*
* @param tabName
* - 表名
* @param values
* - 带键值的HashMap
* @return bool值，成功返回true，失败返回false
*/
public boolean dbInsert(String tabName, HashMap<String, String> values) {
if (!dbConnection())
return false;
String sql = "";
String insertFields = "";
String insertValues = "";
for (Entry<String, String> kvs : values.entrySet()) {
insertFields += "`" + kvs.getKey() + "`, ";
insertValues += "'" + kvs.getValue() + "', ";
}
insertFields = insertFields.substring(0, insertFields.length() - 2);
insertValues = insertValues.substring(0, insertValues.length() - 2);
sql += "INSERT INTO `" + tabName + "` (" + insertFields + ") VALUES" + "(" + insertValues + ")";
try {
dbstate.executeUpdate(sql);
return true;
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
return false;
}
}// end dbInsert(…)
/**
* 对数据库表进行选择操作！
*
* @param tableName
* 数据库表名
* @param fieles
* 字段名
* @param selCondition
* 选择条件
* @return 一个含有map的List（列表）
*/
@SuppressWarnings({ "rawtypes", "unchecked" })
public List dbSelect(String tableName, List<String> fields, String selCondition) {
if (!dbConnection())
return null;
List mapInList = new ArrayList();
String selFields = "";
for (int i = 0; i < fields.size(); ++i)
selFields += fields.get(i) + ", ";
String selFieldsTem = selFields.substring(0, selFields.length() - 2);// 根据String的索引提取子串
String sql = "SELECT " + selFieldsTem + " FROM `" + tableName + "`" + selCondition == "" ? "" : " WHERE " + selCondition;
try {
dbstate = dbconn.createStatement();
try {
dbresult = dbstate.executeQuery(sql);
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
}
while (dbresult.next()) {
Map selResult = new HashMap();
for (String col : fields)
selResult.put(col, dbresult.getString(col));
mapInList.add(selResult);
}
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
}
return mapInList;
}// end String dbSelect(…)
/**
* 对数据库表进行选择操作！
*
* @param tableName
* 数据库表名
* @param fieles
* 字段名
* @param selCondition
* 选择条件
* @return 首个符合条件的结果
*/
public String dbSelectFirst(String tableName, String fields, HashMap<String, String> selConditions) {
if (!dbConnection())
return null;
String selFieldsTem = fields;
String selCondition = "";
if (selConditions != null && !selConditions.isEmpty()) {
for (Entry<String, String> kvs : selConditions.entrySet())
selCondition += kvs.getKey() + "='" + kvs.getValue() + "', ";
selCondition = " WHERE " + selCondition.substring(0, selCondition.length() - 2);// 根据String的索引提取子串
}
String sql = "SELECT " + selFieldsTem + " FROM " + tableName + selCondition + " limit 1";
try {
dbresult = dbstate.executeQuery(sql);
if (dbresult.next())
return dbresult.getString(fields);
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
}
return null;
}
/**
* 对数据库表中记录进行更新操作
*
* @param tabName
* @param reCount
* @return bool值，成功返回true，失败返回false
*/
@SuppressWarnings({ "rawtypes" })
public boolean dbUpdate(String tabName, HashMap reCount, String upCondition) {
if (!dbConnection())
return false;
String Values = "";
Iterator keyValues = reCount.entrySet().iterator();
for (int i = 0; i < reCount.size(); ++i) {
Map.Entry entry = (Map.Entry) keyValues.next();
Object key = entry.getKey();
Object value = entry.getValue();
Values += key + "='" + value + "'" + ", ";
}
String updateValues = Values.substring(0, Values.length() - 2);
String sql = "UPDATE `" + tabName + "` SET " + updateValues + " " + upCondition;
try {
dbstate.executeUpdate(sql);
return true;
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL查询语句: " + sql);
return false;
}
}// end dbUpdate(…)
/**
* 判断数据表是否存在
*
* @param table
* - 表名
* @return 是否存在
*/
public boolean isTableExists(final String table) {
try {
if (!dbConnection())
return false;
final DatabaseMetaData dbm = dbconn.getMetaData();
final ResultSet tables = dbm.getTables(null, null, table, null);
return tables.next();
} catch (final SQLException e) {
e.printStackTrace();
}
return false;
}
public void print(String str)// 简化输出
{
System.out.println(str);
}
/**
* 运行SQL语句
*
* @param sql
* - SQL语句
* @return 运行结果
*/
public boolean runSql(String sql) {
if (!dbConnection())
return false;
try {
PreparedStatement state = dbconn.prepareStatement(sql);
state.executeUpdate();
state.close();
return true;
} catch (final Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL语句: " + sql);
}
return false;
}
/**
* 运行SQL文件
*
* @param sql
* - SQL文件
* @return 运行结果
*/
public boolean runSqlfile(File file) {
BufferedReader br = null;
Statement state = null;
String sql = null;
if (!file.exists())
return false;
if (!dbConnection())
return false;
try {
print("执行SQL文件: " + file.getName() + " ...");
br = new BufferedReader(new FileReader(file));
state = dbconn.createStatement();
while ((sql = br.readLine()) != null)
if (sql != "")
try {
state.executeUpdate(sql);
} catch (Exception e) {
print("数据库操作出错: " + e.getMessage());
print("SQL语句: " + sql);
}
return true;
} catch (Exception e) {
print("执行SQL文件 " + file.getName() + "出错: " + e.getMessage());
return false;
} finally {
try {
if (state != null)
state.close();
if (br != null)
br.close();
} catch (Exception e) {
}
}
}
}

39
src/main/java/cn/citycraft/Yum/sql/SQLiteHelper.java
View File

@ -1,39 +0,0 @@
package cn.citycraft.Yum.sql;
// import java.sql.*;
/**
* 数据库操作类
*
* @author 蒋天蓓 2015年7月14日下午3:25:06
*/
public class SQLiteHelper extends SQLHelper {
private static String drivername = "org.sqlite.JDBC";
/**
* 初始化连接信息
*
* @param host
* - 域名
* @param port
* - 端口
* @param dbname
* - 数据库
* @param username
* - 用户名
* @param password
* - 密码
*/
public SQLiteHelper(String filepath, String username, String password) {
super(password, password, drivername, getUrl(filepath));
}
public static String getUrl(String filepath) {
return "jdbc:sqlite:" + filepath;
}
//
// Class.forName("org.sqlite.JDBC");
// Connection conn =
// DriverManager.getConnection("jdbc:sqlite:filename");//filename为你的SQLite数据名称
}

47
src/main/java/cn/citycraft/Yum/utils/FileUtil.java
View File

@ -1,47 +0,0 @@
/**
*
*/
package cn.citycraft.Yum.utils;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
/**
* 文件处理工具
*
* @author 蒋天蓓
* 2015年8月31日上午9:09:54
*/
public class FileUtil {
/**
* 复制文件
*
* @param src
* - 源文件
* @param des
* - 目标文件
* @return 是否成功
*/
public static boolean copyFile(File src, File des) {
InputStream inStream = null;
FileOutputStream fs = null;
try {
int byteread = 0;
if (!src.exists())
return false;
inStream = new FileInputStream(src); // 读入原文件
fs = new FileOutputStream(des);
byte[] buffer = new byte[1024];
while ((byteread = inStream.read(buffer)) != -1) {
fs.write(buffer, 0, byteread); // 写入到目标文件
}
inStream.close();
fs.close();
return true;
} catch (Exception e) {
return false;
}
}
}