调用示例：
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Web;
using System.Web.UI.WebControls;
namespace WebApplicationTest
{
/// <summary>
/// 定义数据库操作类,用于查询和操作本地数据信息
/// 示例：DataBase newDataBase3 = new DataBase("newDataBase3", "sa", "12345");
/// </summary>
public class DataBase
{
private string DBName = ""; // 数据库名称
private string UserName = ""; // 数据库用户名
private string Password = ""; // 数据库密码
public bool isInitSuccess = false; // 记录指定的数据库是否可以连接成功
public string connectionString = ""; // 当前数据库连接串
public string connectionString_master = "";// 连接到master数据库的连接串
/// <summary>
/// 创建指定数据库操作对象
/// </summary>
/// <param name="DBName">数据库名称</param>
/// <param name="UserName">数据库用户名</param>
/// <param name="Password">数据库密码</param>
public DataBase(string DBName, string UserName, string Password)
{
if (DBName == null || DBName.Equals("") || UserName == null || UserName.Equals("") || Password == null || Password.Equals(""))
{
throw new Exception("DataBase()参数不可为空");
}
this.DBName = DBName;
this.UserName = UserName;
this.Password = Password;
connectionString = DataBaseTool.getConnectString(DBName, UserName, Password);
connectionString_master = DataBaseTool.getConnectString("", UserName, Password);
//if (this.DBName != null && !this.DBName.Equals("") && !this.DBName.Equals("master"))
{
if (!DataBaseTool.Exist(DBName, connectionString_master)) // 判断数据库是否存在，若不存在则创建数据库
{
isInitSuccess = DataBaseTool.Create(DBName, connectionString_master);
}
else isInitSuccess = true;
}
}
public String Execute(string sql)
{
return DataBaseTool.Execute(sql, connectionString);
}
public Dictionary<String, List<String>> ExecuteDic(string sql)
{
return DataBaseTool.ExecuteDic(sql, connectionString);
}
public List<String> ExecuteList(string sql)
{
return DataBaseTool.ExecuteList(sql, connectionString);
}
/// <summary>
/// 连接数据库,执行sql语句,返回Table表
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public Table ExecuteTable(string sql)
{
return DataBaseTool.ExecuteTable(sql, connectionString);
}
/// <summary>
/// 所有数据库名称
/// </summary>
public List<String> DataBaseNames()
{
return DataBaseTool.DataBaseNames(connectionString_master);
}
/// <summary>
/// 当前数据中，所有表名称
/// </summary>
public List<String> TableNames()
{
string sql = "select name from sysobjects where xtype='U'";
List<string> list = ExecuteList(sql);
return list;
}
/// <summary>
/// 删除指定的数据库
/// </summary>
public bool DeletDataBase(string DataBaseName)
{
if (DataBaseName == null || DataBaseName.Equals("")) DataBaseName = DBName;
return DataBaseTool.Delet(DataBaseName, connectionString_master);
}
#region 数据库表操作
/// <summary>
/// 判断当前数据库中，是否存在指定名称的表
/// </summary>
/// <param name="TAB">表名称</param>
public bool ExistTab(string TAB)
{
return DataBaseTool.ExistTab(TAB, connectionString);
}
/// <summary>
/// 在当前数据库中创建数据表
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="Colums">所有列名称</param>
public bool CreateTable(String TAB, List<string> Colums)
{
if (Colums.Count==0) Colums = new String[] { "KEY", "VALUE" }.ToList(); // 未指定列名称时，默认添加KEY、VALUE两列
Dictionary<string, int> ColumnInfo = new Dictionary<string, int>();
foreach (string col in Colums)
{
ColumnInfo.Add(col, 100);
}
//ColumnInfo.Add("EXT", 300); // 默认添加一个拓展字段列
return DataBaseTool.CreateTable(TAB, ColumnInfo, connectionString);
}
/// <summary>
/// 在当前数据库中创建数据表
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="ColumnInfo">所有列信息</param>
/// <returns></returns>
public bool CreateTable(String TAB, Dictionary<string, int> ColumnInfo)
{
return DataBaseTool.CreateTable(TAB, ColumnInfo, connectionString);
}
/// <summary>
/// 删除当前数据库中的TAB表
/// </summary>
public bool DeletTable(String TAB)
{
return DataBaseTool.DeletTable(TAB, connectionString);
}
/// <summary>
/// 向表中插入新的数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="values">列数据</param>
/// <returns>新生成的数据行ID</returns>
public string InsetValue(string TAB, List<string> values)
{
return DataBaseTool.InsetValue(TAB, values, connectionString);
}
/// <summary>
/// 删除TAB表中，KeyName为KeyValue的所有行
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="KeyValue">键值</param>
/// <param name="KeyName">键名称</param>
/// <returns></returns>
public bool DeletValue(string TAB, string KeyValue, string KeyName = "ID")
{
return DataBaseTool.DeletValue(TAB, KeyValue, connectionString, KeyName);
}
/// <summary>
/// 修改TAB表所有标签为KEY的所有数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="KeyValue">主键值</param>
/// <param name="datas">待修改的数据信息</param>
/// <param name="connectionString"></param>
/// <param name="KeyName">主键名称</param>
/// <returns></returns>
public string UpdateValue(string TAB, string KeyValue, Dictionary<string, string> datas, string KeyName = "ID")
{
return DataBaseTool.UpdateValue(TAB, KeyValue, datas, connectionString, KeyName);
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public string SelectValue(string TAB, string KeyValue, string KeyName = "ID", List<string> columns = null)
{
return DataBaseTool.SelectValue(TAB, KeyValue, connectionString, KeyName, columns);
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="connectionString"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public List<string> SelectValueList(string TAB, string KeyValue, string KeyName = "ID", List<string> columns = null)
{
return DataBaseTool.SelectValueList(TAB, KeyValue, connectionString, KeyName, columns);
}
#endregion
}
/// <summary>
/// 数据库静态操作函数
/// </summary>
public class DataBaseTool
{
/// <summary>
/// 获取数据库的连接字符串
/// </summary>
/// <param name="DBName">数据库名称</param>
/// <param name="UserName">用户名称</param>
/// <param name="Password">密码</param>
public static string getConnectString(string DBName, string UserName, string Password)
{
if (DBName == null || DBName.Equals("")) DBName = "master";
if (UserName == null || UserName.Equals("")) return "UserName不可为空";
if (Password == null || Password.Equals("")) return "Password不可为空";
string connectionString = @"Data Source=.\JSQL2008;Initial Catalog=" + DBName + ";User ID=" + UserName + ";Password=" + Password + ""; // 连接本地数据库DBName
// connectionString = @"Data Source=.\SQLEXPRESS;AttachDbFilename=|DataDirectory|\NoteBook.mdf;Integrated Security=True;User Instance=True"; // 连接附加数据库
// connectionString = @"Data Source=.\JSQL2008;Initial Catalog=DataBase1;User ID=sa;Password=12345"; // 连接本地数据库DataBase1
return connectionString;
}
// 1、----------
/// <summary>
/// 连接数据库,执行sql语句
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static String Execute(string queryString, string connectionString)
{
try
{
//string queryString = "SELECT * FROM 数据表1";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand command = new SqlCommand(queryString, connection);
SqlDataReader reader = command.ExecuteReader();
String jsonData = ToJson(reader); // 转化为Json数据
if (jsonData.Trim().Equals("")) jsonData = "success";
connection.Close();
return jsonData;
}
}
catch (Exception ex)
{
return "fail";
}
}
/// <summary>
/// DataReader转换为Json串
/// </summary>
public static string ToJson(SqlDataReader dataReader)
{
StringBuilder Builder = new StringBuilder();
int rows = 0;
while (dataReader.Read())
{
if (rows++ > 0) Builder.Append(",");
// 行数据转Json
Builder.Append("{");
for (int i = 0; i < dataReader.FieldCount; i++)
{
if (i > 0) Builder.Append(",");
// 列名称
string strKey = dataReader.GetName(i);
strKey = "\"" + strKey + "\"";
// 列数据
Type type = dataReader.GetFieldType(i);
string strValue = dataReader[i].ToString();
strValue = String.Format(strValue, type).Trim();
if (type == typeof(string) || type == typeof(DateTime)) strValue = "\"" + strValue + "\"";
Builder.Append(strKey + ":" + strValue);
}
Builder.Append("}");
}
dataReader.Close();
if (rows > 1) return "[" + Builder.ToString() + "]";
else return Builder.ToString();
}
// 2、----------
/// <summary>
/// 连接数据库,执行sql语句
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static Dictionary<String, List<String>> ExecuteDic(string queryString, string connectionString)
{
try
{
//string queryString = "SELECT * FROM 数据表1";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand command = new SqlCommand(queryString, connection);
SqlDataReader reader = command.ExecuteReader();
Dictionary<String, List<String>> dic = ToDictionary(reader); // 转化为列list数据
connection.Close();
return dic;
}
}
catch (Exception ex)
{
return new Dictionary<string, List<string>>();
}
}
/// <summary>
/// DataReader转换为列list数据
/// </summary>
public static Dictionary<String, List<String>> ToDictionary(SqlDataReader dataReader)
{
Dictionary<String, List<String>> Dic = new Dictionary<string, List<string>>();
while (dataReader.Read())
{
// 行数据转Json
for (int i = 0; i < dataReader.FieldCount; i++)
{
// 列名称
string strKey = dataReader.GetName(i);
List<String> list = null;
if (!Dic.ContainsKey(strKey))
{
list = new List<string>(); // 生成新的list
Dic.Add(strKey, list);
}
else list = Dic[strKey]; // 获取列名对应的list
// 列数据
Type type = dataReader.GetFieldType(i);
string strValue = dataReader[i].ToString();
strValue = String.Format(strValue, type).Trim();
list.Add(strValue);
}
}
dataReader.Close();
return Dic;
}
// 3、----------
/// <summary>
/// 连接数据库,执行sql语句
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static List<String> ExecuteList(string queryString, string connectionString)
{
Dictionary<String, List<String>> dic = ExecuteDic(queryString, connectionString);
List<String> list = getList(dic, 0);
return list;
}
/// <summary>
/// 获取dic的指定列
/// </summary>
/// <param name="dic"></param>
/// <param name="index"></param>
/// <returns></returns>
public static List<String> getList(Dictionary<String, List<String>> dic, int index)
{
List<String> list = new List<string>();
if (dic != null && dic.Count > 0 && 0 <= index && index < dic.Count)
{
List<string> keys = dic.Keys.ToList<string>();
String key = keys[index];
list = dic[key];
}
return list;
}
// 4、----------
/// <summary>
/// 连接数据库,执行sql语句,返回Table表
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static Table ExecuteTable(string queryString, string connectionString)
{
try
{
//string queryString = "SELECT * FROM 数据表1";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand command = new SqlCommand(queryString, connection);
SqlDataReader reader = command.ExecuteReader();
Table table = ToTable(reader); // 转化为列list数据
connection.Close();
return table;
}
}
catch (Exception ex)
{
return new Table();
}
}
/// <summary>
/// DataReader转换为Table表
/// </summary>
public static Table ToTable(SqlDataReader dataReader)
{
Table table = new Table();
table.Attributes.Add("border", "1"); // 添加边框线
table.Attributes.Add("BorderStyle", "Solid");
table.Attributes.Add("width", "100%"); // 表格宽度
table.Attributes.Add("cellspacing", "0");
table.Attributes.Add("bordercolor", "DarkGray");
TableHeaderRow header = new TableHeaderRow();
bool firstrow = true;
while (dataReader.Read())
{
TableRow row = new TableRow();
// 行数据转Json
for (int i = 0; i < dataReader.FieldCount; i++)
{
// Tab表头
if (firstrow)
{
string strKey = dataReader.GetName(i); // 列名称
TableHeaderCell headCell = new TableHeaderCell();
headCell.Text = strKey;
header.Cells.Add(headCell);
}
// Tab行数据
Type type = dataReader.GetFieldType(i);
string strValue = dataReader[i].ToString();
strValue = String.Format(strValue, type).Trim();
TableCell cell = new TableCell();
cell.Text = strValue;
row.Cells.Add(cell);
}
if (firstrow)
{
table.Rows.Add(header);
firstrow = false;
}
table.Rows.Add(row);
}
dataReader.Close();
return table;
}
//----------
/// <summary>
/// 判断指定的数据库是否存在
/// </summary>
/// <param name="DataBaseName">数据库名称</param>
public static bool Exist(string DataBaseName, string connectString)
{
string sql = "select count(*) From master.dbo.sysdatabases where name='" + DataBaseName + "'";
String result = Execute(sql, connectString);
return (!result.Equals("{\"\":0}") && !result.Equals("fail"));
}
/// <summary>
/// 创建指定名称的数据库
/// </summary>
/// <param name="DataBaseName">数据库名称</param>
public static bool Create(string DataBaseName, string connectionString)
{
string sql = "CREATE DATABASE \"" + DataBaseName + "\"";
String result = Execute(sql, connectionString);
return result.Equals("success");
}
/// <summary>
/// 获取取所有数据库名称
/// </summary>
public static List<string> DataBaseNames(string connectionString)
{
string sql = "select name From master.dbo.sysdatabases";
List<string> list = ExecuteList(sql, connectionString);
return list;
}
/// <summary>
/// 删除指定的数据库
/// </summary>
public static bool Delet(string DataBaseName, string connectionString)
{
string sql = "DROP DATABASE \"" + DataBaseName + "\"";
String result = Execute(sql, connectionString);
return result.Equals("success");
}
#region 数据库表操作
/// <summary>
/// 判断数据库中是否存在指定名称的表
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="connectionString">数据库连接串</param>
/// <returns></returns>
public static Boolean ExistTab(string TAB, string connectionString)
{
// 查询表是否存在： select name from sys.tables where name='数据表1'
String sql = "select name from sys.tables where name='" + TAB + "'";
List<string> resultList = ExecuteList(sql, connectionString);
String data = resultList.Count == 0 ? "" : resultList[0];
return (data.Equals(TAB));
}
/// <summary>
/// 创建指定名称的表
/// </summary>
/// <param name="TAB">数据表名称</param>
/// <param name="ColumnInfo">列名称，列长度信息</param>
/// <param name="connectionString"></param>
/// <returns></returns>
public static bool CreateTable(String TAB, Dictionary<string, int> ColumnInfo, string connectionString)
{
//if (ExistTab(TAB, connectionString)) return true; // 若已存在数据表，则无需再创建
//CREATE TABLE [dbo].[Log_All]
//(
// [ID] INT NOT NULL PRIMARY KEY IDENTITY(100,1),
// [日期] NCHAR(30) NULL,
// [信息] NCHAR(300) NULL
//)
// 生成数据表sql命令
StringBuilder builder = new StringBuilder();
builder.AppendLine("CREATE TABLE [dbo].[" + TAB + "] ");
builder.AppendLine("( ");
builder.AppendLine(" [ID] INT NOT NULL PRIMARY KEY IDENTITY(100,1), "); // 添加主键ID为自增，从100开始
foreach (string key in ColumnInfo.Keys)
{
string Name = key.Trim();
int Len = ColumnInfo[key];
builder.AppendLine(" [" + Name + "] NCHAR(" + Len + ") NULL, ");
}
builder.AppendLine(") ");
// 执行
String sql = builder.ToString();
String data = Execute(sql, connectionString);
return (data.Trim().ToLower().Equals("success"));
}
/// <summary>
/// 删除当前数据库中的TAB表
/// </summary>
public static bool DeletTable(String TAB, string connectionString)
{
string sql = "DROP TABLE \"" + TAB + "\"";
String result = Execute(sql, connectionString);
return result.Equals("success");
}
/// <summary>
/// 向表中插入新的数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="values">列数据</param>
/// <returns>新生成的数据行ID</returns>
public static string InsetValue(string TAB, List<string> values, string connectionString)
{
//if (!ExistTab(TAB, connectionString)) return "fail"; // 若无数据表，则插入数据失败
//insert into Log_All(日期, 信息) Values('日期1', '信息1')
//insert into Log_All(日期, 信息) output inserted.id Values('日期4', '信息4')
//insert into Log_All output inserted.id Values('日期x', '信息x')
StringBuilder builder = new StringBuilder();
builder.AppendLine("insert into " + TAB + " output inserted.id Values");
builder.AppendLine("( ");
bool isfirst = true;
foreach (string value in values)
{
builder.Append((isfirst ? "\r\n" : ", \r\n") + "'" + value + "'");
isfirst = false;
}
builder.AppendLine(") ");
String sql = builder.ToString();
String data = ExecuteList(sql, connectionString)[0];
return data;
}
/// <summary>
/// 删除TAB表中，KeyName主键值为KeyValue的所有数据项
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="Key">主键值</param>
/// <returns></returns>
public static bool DeletValue(string TAB, string KeyValue, string connectionString, string KeyName = "ID")
{
String sql = "delete from " + TAB + " where " + KeyName + "='" + KeyValue + "'"; ;
String result = Execute(sql, connectionString);
return result.Equals("success");
}
/// <summary>
/// 修改TAB表所有标签为KEY的所有数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="KeyValue">主键值</param>
/// <param name="datas">待修改的数据信息</param>
/// <param name="connectionString"></param>
/// <param name="KeyName">主键名称</param>
/// <returns></returns>
public static string UpdateValue(string TAB, string KeyValue, Dictionary<string, string> datas, string connectionString, string KeyName="ID" )
{
// UPDATE Person SET Address = 'Zhongshan 23', City = 'Nanjing' WHERE LastName = 'Wilson'
StringBuilder builder = new StringBuilder();
bool isFirst = true;
foreach (string key in datas.Keys)
{
builder.Append((isFirst ? " " : ", ") + key + " = " + "'" + datas[key] + "'");
isFirst = false;
}
String sql = "update " + TAB + " set " + builder.ToString() + " where " + KeyName + "='" + KeyValue + "'";
String data = Execute(sql, connectionString);
return data;
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="connectionString"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public static string SelectValue(string TAB, string KeyValue, string connectionString, string KeyName = "ID", List<string> columns = null)
{
string selectColumn = getCondition(columns);
String sql = "select " + selectColumn + " from [" + TAB + "]" + (KeyName.Equals("") ? "" : " where " + KeyName + "='" + KeyValue + "'");
String data = Execute(sql, connectionString);
return data;
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="connectionString"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public static List<string> SelectValueList(string TAB, string KeyValue, string connectionString, string KeyName = "ID", List<string> columns=null)
{
string selectColumn = getCondition(columns);
String sql = "select " + selectColumn + " from [" + TAB + "]" + (KeyName.Equals("") ? "" : " where " + KeyName + "='" + KeyValue + "'");
List<String> list = ExecuteList(sql, connectionString);
return list;
}
/// <summary>
/// 组合paramList中的参数信息
/// </summary>
/// <param name="paramList"></param>
/// <returns></returns>
private static string getCondition(List<string> paramList = null)
{
string Condition = "*";
if (paramList != null && paramList.Count > 0)
{
StringBuilder builder = new StringBuilder();
bool isFirst = true;
foreach (string key0 in paramList)
{
string key = key0.Trim();
if (!key.Equals(""))
{
builder.Append((isFirst ? " " : ", ") + key);
isFirst = false;
}
}
Condition = builder.ToString();
if (Condition.Trim().Equals("")) Condition = "*";
}
return Condition;
}
#endregion
}
}DataBase.cs (使用于SQL数据库)
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Web;
namespace WebApplicationTest
{
/// <summary>
/// 定义数据库操作类,用于查询和操作本地数据信息
/// 示例：DataBase newDataBase3 = new DataBase("newDataBase3", "sa", "12345");
/// </summary>
public class DataBase
{
private string DBName = ""; // 数据库名称
private string UserName = ""; // 数据库用户名
private string Password = ""; // 数据库密码
public bool isInitSuccess = false; // 记录指定的数据库是否可以连接成功
public string connectionString = ""; // 当前数据库连接串
public string connectionString_master = "";// 连接到master数据库的连接串
/// <summary>
/// 创建指定数据库操作对象
/// </summary>
/// <param name="DBName">数据库名称</param>
/// <param name="UserName">数据库用户名</param>
/// <param name="Password">数据库密码</param>
public DataBase(string DBName, string UserName, string Password)
{
if (DBName == null || DBName.Equals("") || UserName == null || UserName.Equals("") || Password == null || Password.Equals(""))
{
throw new Exception("DataBase()参数不可为空");
}
this.DBName = DBName;
this.UserName = UserName;
this.Password = Password;
connectionString = DataBaseTool.getConnectString(DBName, UserName, Password);
connectionString_master = DataBaseTool.getConnectString("", UserName, Password);
//if (this.DBName != null && !this.DBName.Equals("") && !this.DBName.Equals("master"))
{
if (!DataBaseTool.Exist(DBName, connectionString_master)) // 判断数据库是否存在，若不存在则创建数据库
{
isInitSuccess = DataBaseTool.Create(DBName, connectionString_master);
}
else isInitSuccess = true;
}
}
public String Execute(string sql)
{
return DataBaseTool.Execute(sql, connectionString);
}
public Dictionary<String, List<String>> ExecuteDic(string sql)
{
return DataBaseTool.ExecuteDic(sql, connectionString);
}
public List<String> ExecuteList(string sql)
{
return DataBaseTool.ExecuteList(sql, connectionString);
}
/// <summary>
/// 所有数据库名称
/// </summary>
public List<String> DataBaseNames()
{
return DataBaseTool.DataBaseNames(connectionString_master);
}
/// <summary>
/// 当前数据中，所有表名称
/// </summary>
public List<String> TableNames()
{
string sql = "select name from sysobjects where xtype='U'";
List<string> list = ExecuteList(sql);
return list;
}
/// <summary>
/// 删除指定的数据库
/// </summary>
public bool DeletDataBase(string DataBaseName)
{
if (DataBaseName == null || DataBaseName.Equals("")) DataBaseName = DBName;
return DataBaseTool.Delet(DataBaseName, connectionString_master);
}
#region 数据库表操作
/// <summary>
/// 判断当前数据库中，是否存在指定名称的表
/// </summary>
/// <param name="TAB">表名称</param>
public bool ExistTab(string TAB)
{
return DataBaseTool.ExistTab(TAB, connectionString);
}
/// <summary>
/// 在当前数据库中创建数据表
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="Colums">所有列名称</param>
public bool CreateTable(String TAB, List<string> Colums)
{
if (Colums.Count==0) Colums = new String[] { "KEY", "VALUE" }.ToList(); // 未指定列名称时，默认添加KEY、VALUE两列
Dictionary<string, int> ColumnInfo = new Dictionary<string, int>();
foreach (string col in Colums)
{
ColumnInfo.Add(col, 100);
}
//ColumnInfo.Add("EXT", 300); // 默认添加一个拓展字段列
return DataBaseTool.CreateTable(TAB, ColumnInfo, connectionString);
}
/// <summary>
/// 在当前数据库中创建数据表
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="ColumnInfo">所有列信息</param>
/// <returns></returns>
public bool CreateTable(String TAB, Dictionary<string, int> ColumnInfo)
{
return DataBaseTool.CreateTable(TAB, ColumnInfo, connectionString);
}
/// <summary>
/// 删除当前数据库中的TAB表
/// </summary>
public bool DeletTable(String TAB)
{
return DataBaseTool.DeletTable(TAB, connectionString);
}
/// <summary>
/// 向表中插入新的数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="values">列数据</param>
/// <returns>新生成的数据行ID</returns>
public string InsetValue(string TAB, List<string> values)
{
return DataBaseTool.InsetValue(TAB, values, connectionString);
}
/// <summary>
/// 删除TAB表中，KeyName为KeyValue的所有行
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="KeyValue">键值</param>
/// <param name="KeyName">键名称</param>
/// <returns></returns>
public bool DeletValue(string TAB, string KeyValue, string KeyName = "ID")
{
return DataBaseTool.DeletValue(TAB, KeyValue, connectionString, KeyName);
}
/// <summary>
/// 修改TAB表所有标签为KEY的所有数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="KeyValue">主键值</param>
/// <param name="datas">待修改的数据信息</param>
/// <param name="connectionString"></param>
/// <param name="KeyName">主键名称</param>
/// <returns></returns>
public string UpdateValue(string TAB, string KeyValue, Dictionary<string, string> datas, string KeyName = "ID")
{
return DataBaseTool.UpdateValue(TAB, KeyValue, datas, connectionString, KeyName);
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public string SelectValue(string TAB, string KeyValue, string KeyName = "ID", List<string> columns = null)
{
return DataBaseTool.SelectValue(TAB, KeyValue, connectionString, KeyName, columns);
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="connectionString"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public List<string> SelectValueList(string TAB, string KeyValue, string KeyName = "ID", List<string> columns = null)
{
return DataBaseTool.SelectValueList(TAB, KeyValue, connectionString, KeyName, columns);
}
#endregion
}
/// <summary>
/// 数据库静态操作函数
/// </summary>
public class DataBaseTool
{
/// <summary>
/// 获取数据库的连接字符串
/// </summary>
/// <param name="DBName">数据库名称</param>
/// <param name="UserName">用户名称</param>
/// <param name="Password">密码</param>
public static string getConnectString(string DBName, string UserName, string Password)
{
if (DBName == null || DBName.Equals("")) DBName = "master";
if (UserName == null || UserName.Equals("")) return "UserName不可为空";
if (Password == null || Password.Equals("")) return "Password不可为空";
string connectionString = @"Data Source=.\JSQL2008;Initial Catalog=" + DBName + ";User ID=" + UserName + ";Password=" + Password + ""; // 连接本地数据库DBName
// connectionString = @"Data Source=.\SQLEXPRESS;AttachDbFilename=|DataDirectory|\NoteBook.mdf;Integrated Security=True;User Instance=True"; // 连接附加数据库
// connectionString = @"Data Source=.\JSQL2008;Initial Catalog=DataBase1;User ID=sa;Password=12345"; // 连接本地数据库DataBase1
return connectionString;
}
// 1、----------
/// <summary>
/// 连接数据库,执行sql语句
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static String Execute(string queryString, string connectionString)
{
try
{
//string queryString = "SELECT * FROM 数据表1";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand command = new SqlCommand(queryString, connection);
SqlDataReader reader = command.ExecuteReader();
String jsonData = ToJson(reader); // 转化为Json数据
if (jsonData.Trim().Equals("")) jsonData = "success";
connection.Close();
return jsonData;
}
}
catch (Exception ex)
{
return "fail";
}
}
/// <summary>
/// DataReader转换为Json串
/// </summary>
public static string ToJson(SqlDataReader dataReader)
{
StringBuilder Builder = new StringBuilder();
int rows = 0;
while (dataReader.Read())
{
if (rows++ > 0) Builder.Append(",");
// 行数据转Json
Builder.Append("{");
for (int i = 0; i < dataReader.FieldCount; i++)
{
if (i > 0) Builder.Append(",");
// 列名称
string strKey = dataReader.GetName(i);
strKey = "\"" + strKey + "\"";
// 列数据
Type type = dataReader.GetFieldType(i);
string strValue = dataReader[i].ToString();
strValue = String.Format(strValue, type).Trim();
if (type == typeof(string) || type == typeof(DateTime)) strValue = "\"" + strValue + "\"";
Builder.Append(strKey + ":" + strValue);
}
Builder.Append("}");
}
dataReader.Close();
if (rows > 1) return "[" + Builder.ToString() + "]";
else return Builder.ToString();
}
// 2、----------
/// <summary>
/// 连接数据库,执行sql语句
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static Dictionary<String, List<String>> ExecuteDic(string queryString, string connectionString)
{
try
{
//string queryString = "SELECT * FROM 数据表1";
using (SqlConnection connection = new SqlConnection(connectionString))
{
connection.Open();
SqlCommand command = new SqlCommand(queryString, connection);
SqlDataReader reader = command.ExecuteReader();
Dictionary<String, List<String>> dic = ToDictionary(reader); // 转化为列list数据
connection.Close();
return dic;
}
}
catch (Exception ex)
{
return new Dictionary<string, List<string>>();
}
}
/// <summary>
/// DataReader转换为列list数据
/// </summary>
public static Dictionary<String, List<String>> ToDictionary(SqlDataReader dataReader)
{
Dictionary<String, List<String>> Dic = new Dictionary<string, List<string>>();
while (dataReader.Read())
{
// 行数据转Json
for (int i = 0; i < dataReader.FieldCount; i++)
{
// 列名称
string strKey = dataReader.GetName(i);
List<String> list = null;
if (!Dic.ContainsKey(strKey))
{
list = new List<string>(); // 生成新的list
Dic.Add(strKey, list);
}
else list = Dic[strKey]; // 获取列名对应的list
// 列数据
Type type = dataReader.GetFieldType(i);
string strValue = dataReader[i].ToString();
strValue = String.Format(strValue, type).Trim();
list.Add(strValue);
}
}
dataReader.Close();
return Dic;
}
// 3、----------
/// <summary>
/// 连接数据库,执行sql语句
/// queryString = "SELECT * FROM 数据表1";
/// </summary>
public static List<String> ExecuteList(string queryString, string connectionString)
{
Dictionary<String, List<String>> dic = ExecuteDic(queryString, connectionString);
List<String> list = getList(dic, 0);
return list;
}
/// <summary>
/// 获取dic的指定列
/// </summary>
/// <param name="dic"></param>
/// <param name="index"></param>
/// <returns></returns>
public static List<String> getList(Dictionary<String, List<String>> dic, int index)
{
List<String> list = new List<string>();
if (dic != null && dic.Count > 0 && 0 <= index && index < dic.Count)
{
List<string> keys = dic.Keys.ToList<string>();
String key = keys[index];
list = dic[key];
}
return list;
}
//----------
/// <summary>
/// 判断指定的数据库是否存在
/// </summary>
/// <param name="DataBaseName">数据库名称</param>
public static bool Exist(string DataBaseName, string connectString)
{
string sql = "select count(*) From master.dbo.sysdatabases where name='" + DataBaseName + "'";
String result = Execute(sql, connectString);
return (!result.Equals("{\"\":0}") && !result.Equals("fail"));
}
/// <summary>
/// 创建指定名称的数据库
/// </summary>
/// <param name="DataBaseName">数据库名称</param>
public static bool Create(string DataBaseName, string connectionString)
{
string sql = "CREATE DATABASE \"" + DataBaseName + "\"";
String result = Execute(sql, connectionString);
return result.Equals("success");
}
/// <summary>
/// 获取取所有数据库名称
/// </summary>
public static List<string> DataBaseNames(string connectionString)
{
string sql = "select name From master.dbo.sysdatabases";
List<string> list = ExecuteList(sql, connectionString);
return list;
}
/// <summary>
/// 删除指定的数据库
/// </summary>
public static bool Delet(string DataBaseName, string connectionString)
{
string sql = "DROP DATABASE \"" + DataBaseName + "\"";
String result = Execute(sql, connectionString);
return result.Equals("success");
}
#region 数据库表操作
/// <summary>
/// 判断数据库中是否存在指定名称的表
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="connectionString">数据库连接串</param>
/// <returns></returns>
public static Boolean ExistTab(string TAB, string connectionString)
{
// 查询表是否存在： select name from sys.tables where name='数据表1'
String sql = "select name from sys.tables where name='" + TAB + "'";
List<string> resultList = ExecuteList(sql, connectionString);
String data = resultList.Count == 0 ? "" : resultList[0];
return (data.Equals(TAB));
}
/// <summary>
/// 创建指定名称的表
/// </summary>
/// <param name="TAB">数据表名称</param>
/// <param name="ColumnInfo">列名称，列长度信息</param>
/// <param name="connectionString"></param>
/// <returns></returns>
public static bool CreateTable(String TAB, Dictionary<string, int> ColumnInfo, string connectionString)
{
//if (ExistTab(TAB, connectionString)) return true; // 若已存在数据表，则无需再创建
//CREATE TABLE [dbo].[Log_All]
//(
// [ID] INT NOT NULL PRIMARY KEY IDENTITY(100,1),
// [日期] NCHAR(30) NULL,
// [信息] NCHAR(300) NULL
//)
// 生成数据表sql命令
StringBuilder builder = new StringBuilder();
builder.AppendLine("CREATE TABLE [dbo].[" + TAB + "] ");
builder.AppendLine("( ");
builder.AppendLine(" [ID] INT NOT NULL PRIMARY KEY IDENTITY(100,1), "); // 添加主键ID为自增，从100开始
foreach (string key in ColumnInfo.Keys)
{
string Name = key.Trim();
int Len = ColumnInfo[key];
builder.AppendLine(" [" + Name + "] NCHAR(" + Len + ") NULL, ");
}
builder.AppendLine(") ");
// 执行
String sql = builder.ToString();
String data = Execute(sql, connectionString);
return (data.Trim().ToLower().Equals("success"));
}
/// <summary>
/// 删除当前数据库中的TAB表
/// </summary>
public static bool DeletTable(String TAB, string connectionString)
{
string sql = "DROP TABLE \"" + TAB + "\"";
String result = Execute(sql, connectionString);
return result.Equals("success");
}
/// <summary>
/// 向表中插入新的数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="values">列数据</param>
/// <returns>新生成的数据行ID</returns>
public static string InsetValue(string TAB, List<string> values, string connectionString)
{
//if (!ExistTab(TAB, connectionString)) return "fail"; // 若无数据表，则插入数据失败
//insert into Log_All(日期, 信息) Values('日期1', '信息1')
//insert into Log_All(日期, 信息) output inserted.id Values('日期4', '信息4')
//insert into Log_All output inserted.id Values('日期x', '信息x')
StringBuilder builder = new StringBuilder();
builder.AppendLine("insert into " + TAB + " output inserted.id Values");
builder.AppendLine("( ");
bool isfirst = true;
foreach (string value in values)
{
builder.Append((isfirst ? "\r\n" : ", \r\n") + "'" + value + "'");
isfirst = false;
}
builder.AppendLine(") ");
String sql = builder.ToString();
String data = ExecuteList(sql, connectionString)[0];
return data;
}
/// <summary>
/// 删除TAB表中，KeyName主键值为KeyValue的所有数据项
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="Key">主键值</param>
/// <returns></returns>
public static bool DeletValue(string TAB, string KeyValue, string connectionString, string KeyName = "ID")
{
String sql = "delete from " + TAB + " where " + KeyName + "='" + KeyValue + "'"; ;
String result = Execute(sql, connectionString);
return result.Equals("success");
}
/// <summary>
/// 修改TAB表所有标签为KEY的所有数据
/// </summary>
/// <param name="TAB">表名称</param>
/// <param name="KeyValue">主键值</param>
/// <param name="datas">待修改的数据信息</param>
/// <param name="connectionString"></param>
/// <param name="KeyName">主键名称</param>
/// <returns></returns>
public static string UpdateValue(string TAB, string KeyValue, Dictionary<string, string> datas, string connectionString, string KeyName="ID" )
{
// UPDATE Person SET Address = 'Zhongshan 23', City = 'Nanjing' WHERE LastName = 'Wilson'
StringBuilder builder = new StringBuilder();
bool isFirst = true;
foreach (string key in datas.Keys)
{
builder.Append((isFirst ? " " : ", ") + key + " = " + "'" + datas[key] + "'");
isFirst = false;
}
String sql = "update " + TAB + " set " + builder.ToString() + " where " + KeyName + "='" + KeyValue + "'";
String data = Execute(sql, connectionString);
return data;
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="connectionString"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public static string SelectValue(string TAB, string KeyValue, string connectionString, string KeyName = "ID", List<string> columns = null)
{
string selectColumn = getCondition(columns);
String sql = "select " + selectColumn + " from [" + TAB + "]" + (KeyName.Equals("") ? "" : " where " + KeyName + "='" + KeyValue + "'");
String data = Execute(sql, connectionString);
return data;
}
/// <summary>
/// 查询TAB表,KeyName为KeyValue的所有数据项
/// </summary>
/// <param name="TAB"></param>
/// <param name="KeyValue"></param>
/// <param name="connectionString"></param>
/// <param name="KeyName"></param>
/// <param name="columns">查询的列名称</param>
/// <returns></returns>
public static List<string> SelectValueList(string TAB, string KeyValue, string connectionString, string KeyName = "ID", List<string> columns=null)
{
string selectColumn = getCondition(columns);
String sql = "select " + selectColumn + " from [" + TAB + "]" + (KeyName.Equals("") ? "" : " where " + KeyName + "='" + KeyValue + "'");
List<String> list = ExecuteList(sql, connectionString);
return list;
}
/// <summary>
/// 组合paramList中的参数信息
/// </summary>
/// <param name="paramList"></param>
/// <returns></returns>
private static string getCondition(List<string> paramList = null)
{
string Condition = "*";
if (paramList != null && paramList.Count > 0)
{
StringBuilder builder = new StringBuilder();
bool isFirst = true;
foreach (string key0 in paramList)
{
string key = key0.Trim();
if (!key.Equals(""))
{
builder.Append((isFirst ? " " : ", ") + key);
isFirst = false;
}
}
Condition = builder.ToString();
if (Condition.Trim().Equals("")) Condition = "*";
}
return Condition;
}
#endregion
}
}