Question

怎样在C#中调用SQL

Answer 1

楼上的网页其实挺好的，但是我相信提问者想要一个例子，然后能够直接使用的。
提问者可以新建一个类然后贴上如下代码。这个类集合了操作数据库的很多的方法，程序中直接调用即可。
文件名DataBase.cs
以下是内容：
using System;
using System.Data;
using System.Collections;
using System.Data.SqlClient;
using System.Configuration;
// 数据库接口类
public class DataBase
{
//私有变量，数据库连接
protected SqlConnection Connection;
protected string ConnectionString;
//构造函数
public DataBase()
{
ConnectionString = "User id=sa;Password=sa;Database=qqq;Server=.;Connect Timeout=5;Max Pool size=200;Min pool Size=5;enlist=false;";
//这里是数据库的链接字符串
//链接时需要修改用户名、密码和数据库名称
}
//保护方法，打开数据库连接
private void Open()
{
//判断数据库连接是否存在
if (Connection == null)
{
//不存在，新建并打开
Connection = new SqlConnection(ConnectionString);
Connection.Open();
}
else
{
//存在，判断是否处于关闭状态
if (Connection.State.Equals(ConnectionState.Closed))
Connection.Open(); //连接处于关闭状态，重新打开
}
}
//公有方法，关闭数据库连接
public void Close()
{
if (Connection.State.Equals(ConnectionState.Open))
{
Connection.Close(); //连接处于打开状态，关闭连接
}
}
/// <summary>
/// 析构函数，释放非托管资源
/// </summary>
~DataBase()
{
try
{
if (Connection != null)
Connection.Close();
}
catch { }
try
{
Dispose();
}
catch { }
}
//公有方法，释放资源
public void Dispose()
{
if (Connection != null) // 确保连接被关闭
{
Connection.Dispose();
Connection = null;
}
}
//公有方法，根据Sql语句，返回是否查询到记录
public bool GetRecord(string XSqlString)
{
Open();
SqlDataAdapter adapter = new SqlDataAdapter(XSqlString, Connection);
DataSet dataset = new DataSet();
adapter.Fill(dataset);
Close();
if (dataset.Tables[0].Rows.Count > 0)
{
return true;
}
else
{
return false;
}
}
//公有方法，返回Sql语句获得的时间值
//SqlString的格式：select 字段 from XXX where ...
public DateTime GetRecordDateTime(string XSqlString)
{
string SCount;
Open();
SqlCommand Cmd = new SqlCommand(XSqlString, Connection);
SCount = Cmd.ExecuteScalar().ToString().Trim();
if (SCount == "")
SCount = "0";
Close();
return Convert.ToDateTime(SCount);
}
//公有方法，返回Sql语句获得的数据值
//SqlString的格式：select (XXX) from XXX where ...
// select distinct(XXX) from YYY where ...
public string GetRecordChar(string XSqlString)
{
string SCount;
Open();
SqlCommand Cmd = new SqlCommand(XSqlString, Connection);
try
{
SCount = Cmd.ExecuteScalar().ToString().Trim();
}
catch (Exception)
{
SCount = "";
}
if (SCount == "")
SCount = "";
Close();
return SCount;
}
//公有方法，返回Sql语句获得的数据值
//SqlString的格式：select count(*) from XXX where ...
// select max(XXX) from YYY where ...
public int GetRecordCount(string XSqlString)
{
string SCount;
Open();
SqlCommand Cmd = new SqlCommand(XSqlString, Connection);
try
{
SCount = Cmd.ExecuteScalar().ToString().Trim();
}
catch (Exception)
{
SCount = "";
}
if (SCount == "")
SCount = "0";
Close();
return Convert.ToInt32(SCount);
}
//公有方法，返回Sql语句获得的数据值,含小数
//SqlString的格式：select count(*) from XXX where ...
// select max(XXX) from YYY where ...
public Decimal GetRecordPrice(string XSqlString)
{
string SCount;
Open();
SqlCommand Cmd = new SqlCommand(XSqlString, Connection);
try
{
SCount = Cmd.ExecuteScalar().ToString().Trim();
}
catch (Exception)
{
SCount = "";
}
if (SCount == "")
SCount = "0";
Close();
return Convert.ToDecimal(SCount);
}
//公有方法，根据XWhere更新数据表XTableName中的某些纪录
//XTableName --表名
//XHT --哈希表，键为字段名，值为字段值
public DataSet AdvancedSearch(string XTableName, Hashtable XHT)
{
int Count = 0;
string Fields = "";
foreach (DictionaryEntry Item in XHT)
{
if (Count != 0)
{
Fields += " and ";
}
Fields += Item.Key.ToString();
Fields += " like '%";
Fields += Item.Value.ToString();
Fields += "%'";
Count++;
}
Fields += " ";
string SqlString = "select * from " + XTableName + " where " + Fields;
Open();
SqlDataAdapter Adapter = new SqlDataAdapter(SqlString, Connection);
DataSet Ds = new DataSet();
Adapter.Fill(Ds);
Close();
return Ds;
}
//私有方法，获得一个用来调用存储过程的SqlCommand
//输入：
// ProcName - 存储过程名
// Params - 用来调用存储过程的参数表
private SqlCommand CreateCommand(string ProcName, SqlParameter[] Prams)
{
Open();
SqlCommand Cmd = new SqlCommand(ProcName, Connection);
Cmd.CommandType = CommandType.StoredProcedure;
if (Prams != null)
{
foreach (SqlParameter Parameter in Prams)
Cmd.Parameters.Add(Parameter);
}
return Cmd;
}
//公有方法，实例化一个用于调用存储过程的参数
//输入：
// ParamName - 参数名称
// DbType - 参数类型
// Size - 参数大小
// Direction - 传递方向
// Value - 值
public SqlParameter MakeParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value)
{
SqlParameter Param;
if (Size > 0)
Param = new SqlParameter(ParamName, DbType, Size);
else Param = new SqlParameter(ParamName, DbType);
Param.Direction = Direction;
if (Value != null)
Param.Value = Value;
return Param;
}
//公有方法，实例化一个用于调用存储过程的输入参数
//输入：
// ParamName - 参数名称
// DbType - 参数类型
// Size - 参数大小
// Value - 值
public SqlParameter MakeInParam(string ParamName, SqlDbType DbType, int Size, object Value)
{
return MakeParam(ParamName, DbType, Size, ParameterDirection.Input, Value);
}
//公有方法，调用存储过程(不带参数)
//输入：
// ProcName存储过程名
//输出：
// 对Update、Insert、Delete操作返回影响到的行数，其他情况为-1
public int RunProc(string ProcName)
{
int Count = -1;
SqlCommand Cmd = CreateCommand(ProcName, null);
Count = Cmd.ExecuteNonQuery();
Close();
return Count;
}
//公有方法，调用存储过程(带参数)
//输入：
// ProcName - 存储过程名
// Params - 用来调用存储过程的参数表
//输出：
// 对Update、Insert、Delete操作返回影响到的行数，其他情况为-1
public int RunProc(string ProcName, SqlParameter[] Params)
{
int Count = -1;
SqlCommand Cmd = CreateCommand(ProcName, Params);
Count = Cmd.ExecuteNonQuery();
Close();
return Count;
}
//公有方法，调用存储过程(不带参数)
//输入：
// ProcName存储过程名
//输出：
// 将执行结果以SqlDataReader返回
//注意：使用后主意调用SqlDataReader.Close()方法
public SqlDataReader RunProcGetReader(string ProcName)
{
SqlCommand Cmd = CreateCommand(ProcName, null);
return Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
}
//公有方法，调用存储过程(带参数)
//输入：
// ProcName - 存储过程名
// Params - 存储过程需要的参数
//输出：
// 将执行结果以SqlDataReader返回
//注意：使用后主意调用SqlDataReader.Close()方法
public SqlDataReader RunProcGetReader(string ProcName, SqlParameter[] Params)
{
SqlCommand Cmd = CreateCommand(ProcName, Params);
return Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
}
//公有方法，调用存储过程(带输出参数)
//输入：
// ProcName - 存储过程名
// Params - 存储过程需要的参数
// - 输出参数放数组的第一位
//输出：
// 返回输出参数
public string RunProcGetID(string ProcName, SqlParameter[] Params)
{
SqlCommand Cmd = CreateCommand(ProcName, Params);
string SID;
if (Cmd.ExecuteNonQuery() == 0)
SID = "";
else
SID = Cmd.Parameters[0].Value.ToString();
Close();
return SID;
}
//公有方法，调用存储过程(带参数)
//输入：
// ProcName - 存储过程名
// Params - 存储过程需要的参数
//输出：
// 将执行结果以SqlDataReader返回
//注意：使用后主意调用SqlDataReader.Close()方法
public int RunProcGetCount(string ProcName, SqlParameter[] Params)
{
SqlCommand Cmd = CreateCommand(ProcName, Params);
string SCount;
SCount = Cmd.ExecuteScalar().ToString().Trim();
if (SCount == "")
SCount = "0";
Close();
return Convert.ToInt32(SCount);
}
//公有方法，调用存储过程(不带参数)
//输入：
// ProcName存储过程名
//输出：
// 将执行结果以DataSet返回
public DataSet GetDataSet(string ProcName)
{
DataSet dataset = new DataSet();
try
{
Open();
SqlDataAdapter adapter = new SqlDataAdapter(ProcName, Connection);
adapter.Fill(dataset);
Close();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
return dataset;
}
//公有方法，调用存储过程(带参数)
//输入：
// ProcName存储过程名
//输出：
// 将执行结果以DataSet返回
public DataSet GetDataSet(string ProcName, SqlParameter[] Params)
{
//Open();
SqlCommand Cmd = CreateCommand(ProcName, Params);
SqlDataAdapter adapter = new SqlDataAdapter(Cmd);
DataSet dataset = new DataSet();
adapter.Fill(dataset);
Close();
return dataset;
}
//公有方法，根据Sql语句，返回一个结果数据集
public DataSet GetDataSetSql(string XSqlString)
{
Open();
SqlDataAdapter Adapter = new SqlDataAdapter(XSqlString, Connection);
DataSet Ds = new DataSet();
Adapter.Fill(Ds);
Close();
return Ds;
}
//公有方法，根据Sql语句，插入记录
public int Insert(string XSqlString)
{
int Count = -1;
Open();
SqlCommand cmd = new SqlCommand(XSqlString, Connection);
try
{
Count = cmd.ExecuteNonQuery();
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
}
Close();
return Count;
}
//公有方法，根据Sql语句，插入记录并返回生成的ID号
public int GetIDInsert(string XSqlString)
{
int Count = -1;
Open();
SqlCommand cmd = new SqlCommand(XSqlString, Connection);
try
{
Count = int.Parse(cmd.ExecuteScalar().ToString().Trim());
}
catch (Exception)
{ }
Close();
return Count;
}
//公有方法，根据Sql语句，执行备份或还原数据库
public int bak(string XSqlString)
{
int Count = 0;
Open();
SqlCommand cmd = new SqlCommand(XSqlString, Connection);
try
{
Count = cmd.ExecuteNonQuery();
Count = 0;
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
Count = -1;
}
Close();
return Count;
}
}
下面是调用的举例
//实例化
DataBase db = new DataBase();
//将数据库中的内容填充combobox控件
cmb_Scope.Items.Clear();
string sqlstr = "select distinct scope from equipment";
cmb_Scope.DataSource = db.GetDataSetSql(sqlstr).Tables[0];
cmb_Scope.DisplayMember = "scope";
cmb_state.SelectedIndex = 0;
//执行语句
string sqlstr1 = string.Format("update equipment set x0 =“1”);
db.Insert(sqlstr1);

Answer 2

http://hi.baidu.com/longsihanyuan/blog/item/2a3711af56d85de4faed5048.html