废话说少吧,发代码才是硬道理。。。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data;
namespace TestCSharpBasic
{
class SQLHelper
{
private string strError = null;
private int intCount = 0;
public SQLHelper()
{
}
/// <summary>
/// 记录sql日志,日志分等级,level=1是信息,等于0为异常
/// </summary>
/// <param name="str">日志信息</param>
/// <param name="level">日志等级</param>
public void Log(string str,int level)
{
string levelStr = "信息:";
if (level == 1)
{
levelStr = "信息:";
}
else
{
levelStr = "错误:";
}
Console.WriteLine(levelStr + str);
}
/// <summary>
/// 获取数据库连接
/// </summary>
/// <returns>数据库连接对象SqlConnection</returns>
public SqlConnection GetConn()
{// connstr = "Server=(local);DataBase=GlobalMeetings;Uid=sa;pwd=00"
string connStr = "Data Source=.\\SQLEXPRESS;Database=MyStockDB;Integrated Security=SSPI;";
SqlConnection conn = null;
try
{
conn = new SqlConnection(connStr);
}
catch (Exception ex)
{
Log(ex.Message,0);
// throw;
}
return conn;
}
/// <summary>
/// 公开属性ErrorMessage,反悔错误信息
/// </summary>
public string ErrorMessage
{
get
{
return strError;
}
}
/// <summary>
/// 查询数据库到dataset中
/// </summary>
/// <param name="SelectString">查询语句</param>
/// <param name="sqlConn">数据库连接</param>
/// <returns>数据结果集</returns>
public DataSet Select(string SelectString, SqlConnection sqlConn)
{
strError = "";
SqlConnection conn;
if (sqlConn == null)
{
conn = GetConn();
}
else
{
conn = sqlConn;
}
try
{
if (conn.State == ConnectionState.Closed)
{
conn.Open();
}
SqlDataAdapter adapter = new SqlDataAdapter();
SqlCommand selectCmd = new SqlCommand(SelectString, conn);
selectCmd.CommandType = CommandType.Text;
adapter.SelectCommand = selectCmd;
DataSet ds = new DataSet();
adapter.Fill(ds);
return ds;
}
catch (Exception e)
{
strError = "数据检索失败,错误信息:" + e.Message;
return null;
}
finally
{
if (conn.State != ConnectionState.Closed)
{
conn.Close();
}
}
}
// 更新 ,删除,插入
public bool Update(string UpdateString, SqlConnection SqlConn)
{
return udiDataBase(UpdateString,SqlConn);
}
public bool Delete(string DeleteString, SqlConnection SqlConn)
{
return udiDataBase(DeleteString, SqlConn);
}
public bool Insert(string InsertString, SqlConnection SqlConn)
{
return udiDataBase(InsertString, SqlConn);
}
// 更新数据库
public bool udiDataBase(string UDIString, SqlConnection sqlConn)
{
strError = "";
SqlConnection conn;
if (sqlConn == null)
{
conn = GetConn();
}
else
{
conn = sqlConn;
}
try
{
if (conn.State == ConnectionState.Closed)
{
conn.Open();
}
SqlCommand selectCmd = new SqlCommand(UDIString, conn);
selectCmd.CommandType = CommandType.Text;
intCount = selectCmd.ExecuteNonQuery();
return !(intCount<1);
}
catch (Exception e)
{
strError = "数据检索失败,错误信息:" + e.Message;
return false;
}
finally
{
if (conn.State != ConnectionState.Closed)
{
conn.Close();
}
}
}
}
}
------------------------------------------调用部分---------------------------------------------------
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Data;
namespace TestCSharpBasic
{
class Program
{
static void Main(string[] args)
{
Console.WriteLine("------start------");
// Check_User(username:"Mr.Chen");
// TestConn();
//测试表结构
/***
* Create Table Users
* (ID int IDENTITY PRIMARY KEY
* UserName nvarchar(50)
* PassWord nvarchar(50)
* );
* **/
// 查询
SQLHelper hp = new SQLHelper();
SqlConnection conn = hp.GetConn();
DataSet ds = hp.Select("select * from users",conn);
for (int a = 0; a < ds.Tables[0].Rows.Count;a++ )
{
Console.WriteLine(" ID:{0} UserName:{1},Password:{2} ",
ds.Tables[0].Rows[a][0],
ds.Tables[0].Rows[a][1],
ds.Tables[0].Rows[a][2]);
}
// 插入数据
bool exec;
string insertSql = "insert into users(username,password) values ('chen1','111')";
string updateSql = "update users set username = 'chenliang' where username='chen1'";
string deleteSql = "delete from users where id = 2";
// exec = hp.Insert(insertSql, conn);
// exec = hp.Update(updateSql, conn);
exec = hp.Delete(deleteSql, conn);
if(exec){
Console.WriteLine("操作成功!");
}
Console.WriteLine("------ end ------");
Console.ReadLine();
}
// 可选参数
static void Check_User(string username,string pwd="123")
{
Console.WriteLine(" username:{0},password:{1}.",username,pwd);
}
// 连接数据库
public static void TestConn()
{
string connStr = "Data Source=.\\SQLEXPRESS;Database=MyStockDB;Integrated Security=SSPI;";
SqlConnection conn = new SqlConnection(connStr);
if (conn != null)
{
Console.WriteLine("------ Connect SQLExpress Success! ------");
}
else
{
Console.WriteLine("------ Unknow ------");
}
}
public int MyProperty { get; set; }
}
}
分享到:
相关推荐
SQL数据库类 C#SQL数据库源码 C#SQL数据库源 SQL数据库访问 C#ACCESS数据库操作
C# 实现SQL SERVER数据库操作类,很方便的使用的。
C#的sqlserver数据库操作封装类,封装了sql语句的查询、修改、插入、删除操作,以及存储过程的执行,包括有输入、输出参数的存储过程,存储过程的执行无需输入任何参数名称,只需输入参数值即可。同时封装了大批量...
该文档为C#数据库操作类,通过该类可直接连接SQL数据库,并进行数据的更新,查询等操作,并且给出了数据库配置文件config.xml的内容
C#操作sql server 的类分装,用于大部分的操作,修改,删除,添加,存储过程等等。
C#操作SQL Server数据库通用类.doc
c#sql数据库操作,包括添加数据,查询数据!
C#-SQLServer数据库操作类技术手册
数据库操作通用类(C#) 可是各种数据库。
微软官方发布的SQL server数据库操作类(C#),自测稳定实用
C#实现的SQL数据库操作类,这是一个比较严谨、齐全、高效的数据库操作类,有兴趣的朋友可以下载学习参考。
(C#)Oracle数据库操作类(操作sql语句)
C#SQL数据库操作通用类,运行SQL语句。 运行SQL语句返回DataReader,SqlDataReader对象;生成Command对象;返回adapter对象;运行SQL语句,返回DataSet对象;返回SQL语句执行结果的第一行第一列;返回SQL语句第一列,...
C#程序开发中,用于数据库操作 输入数据库Tsql语句即可得到想要的数据库执行结果、操作
实现增删改查功能,调用函数时候只要输入表名和条件,省去大量代码。 查询多个数据默认是用dataset接收数据
C#SQL数据库操作类[文].pdf
C#ACCESS数据操作类,执行SQL语句以及返回DataSet
包括最基本的方法: 打开数据库 关闭数据库 创建SqlCommand命令方法 执行SQL语句方法 将DataReader对象转换成DataTable对象方法
提供了一个用C#语言实现的SQL Server数据库操作类,实现了对SQL Server数据库(本地或者远程数据库)的链接、查询、插入、删除、更新等功能,调用方便,操作简单,并附有使用说明。如有问题,请发送邮件至gaocongly@...