C# 对SqlServer数据库增删改查

2023-11-10 来源：六九美食网

http://www.worlduc.com/blog2012.aspx?bid=730767

用C#sqlserver实现增删改查

using System;using System.Collections.Generic;using System.Text;using System.Data;using System.Data.Sql;using System.Data.SqlClient;

namespace ConsoleApplication2{ class Program { static void Main(string[] args) {

while (true) { SqlConnection con = new SqlConnection(); con.ConnectionString = "server=505-03;database=ttt;user=sa;pwd=123"; con.Open(); SqlCommand cmd = new SqlCommand(); cmd.Connection = con; string sql="";

Console.WriteLine("增加请输入1；删除请输入2；修改请输入3；查找请输入4"); int i = Convert.ToInt32(Console.ReadLine()); string str = ""; switch (i) { case 1: sql = "insert into "; Console.WriteLine("请输入你要修改的表"); str = Console.ReadLine(); sql += str + "("; Console.WriteLine("请输入你要修改的列名，用逗号隔开"); str = Console.ReadLine(); sql += str + ")"; Console.WriteLine("请输入相应的数据，用逗号隔开"); str = Console.ReadLine(); sql += " values (" + str+")"; break; case 2: sql = "DELETE FROM "; Console.WriteLine("请输入表名"); str = Console.ReadLine(); sql += str; Console.WriteLine("请输入删除的条件"); str = Console.ReadLine(); sql += " where " + str; break; case 3: sql = "UPDATE "; Console.WriteLine("请输入表名"); str = Console.ReadLine(); sql += str + " set "; Console.WriteLine("请输入要修改的数据，如money=0,多个用逗号隔开"); str = Console.ReadLine(); sql += str; Console.WriteLine("请输入要修改的条件"); str = Console.ReadLine(); sql += " where " + str; break; case 4: sql = "select "; Console.WriteLine("请输入你要查询的列名，多个用逗号隔开"); str = Console.ReadLine(); sql += str; Console.WriteLine("请输入你要查询的表名，多个用逗号隔开"); str = Console.ReadLine(); sql += " from " + str; break;

} cmd.CommandText = sql; cmd.CommandType = CommandType.Text; cmd.ExecuteNonQuery(); }

} }}

C# 对SqlServer数据库增删改查

标签：[] cmd values sys 条件 pwd log set console

小编还为您整理了以下内容，可能对您也有帮助：

用C#语言实现与SQL server的连接并实现增删改查的功能

用C#sqlserver实现增删改查

http://www.worlc.com/blog2012.aspx?bid=730767

using System.Data;

using System.Data.SqlClient;

//先打开两个类库文件

SqlConnection con = new SqlConnection();

// con.ConnectionString = "server=505-03;database=ttt;user=sa;pwd=123";

con.ConnectionString = "server=.;database=stu;uid=sa;pwd=sa";

con.Open();

SqlDataAdapter 对象。用于填充DataSet （数据集）。

SqlDataReader 对象。从数据库中读取流..

后面要做增删改查还需要用到 DataSet 对象。

SqlCommand com = new SqlCommand();

com.Connection = con;

com.CommandType = CommandType.Text;

com.CommandText = "SQL的语句";

SqlDataReader dr = com.ExecuteReader();//执行SQL语句

dr.Close();//关闭执行

con.Close();//关闭数据库

------------------

使用ASP.NET连接SQLSERVER的步骤：

1.确定你的电脑安装了ASP.NET和SQLSERVER

2.在你需要连接数据库的页面的.aspx页面中添加命名空间using system.data和using system.data.sqlclient

3.实例化常用的类对象：sqlconnection具体方法如下：

SqlConnection SQlConn = new SqlConnection("server = .;uid = sa;pwd = ; database = 你要连接的数据库名称");

这样你就能实现最基本的C#连接数据库了，后面还要实例化SqlCommand对象和DataSet对象，这两个分别是你对数据库实现增，删，改，查的基本操作和生成数据集。

如何用C#语言编写对数据库的添改删查?

比如MSSQL:
//建立数据库连接
SqlConnection SqlConn = new SqlConnection("连接字符串");
//建立SqlCommand
SqlCommand SqlCmd = new SqlCommand("查询语句/存储过程名称", SqlConn);
//指定执行超时时间（毫秒）
SqlCmd.CommandTimeout = 0;
//添加参数
SqlCmd.Parameters.Add("@DateStart", SqlDbType.NVarChar, 25).Value = StartDate;
//指定命令类型Text/存储过程
SqlCmd.CommandType = CommandType.StoredProcere;
//打开连接
if (SqlConn.State == ConnectionState.Closed) SqlConn.Open();
//执行命令
查询
返回数据集
SqlDataReade DataReader = SqlCmd.ExecuteReader();
返回第一行第一列
SqlCmd.ExecuteScalar();
DataSet。。。自己去查查吧
更新，删除
SqlCmd.ExecuteNonQuery();
关闭连接
if (SqlConn.State == ConnectionState.Open) SqlConn.Close();
//释放SqlCommand
SqlCmd.Dispose();
//释放SqlConnection
SqlConn.Dispose();

sql语句就不用我给你说了吧

如何用C#语言编写对数据库的添改删查?

怎么用c#的窗体对数据库进行增删该

添加引用 using System.Data; using System.Data.SqlClient; 定义数据库链接： public SqlConnection sqlconnect = new SqlConnection(“数据库链接"); //链接一般是：Data Source="服务器名字",DataBase="数据库名字",UID="数据库账号",PWD="数据库密码" 定义数据查询SQL（即增删改查操作） SQlcommand sqlcom=new SQlcommand (); sqlcom.Connection=sqlconnect ;//上面定义的链接 “命操作令”//具体操作都写在这,如下 1.删除：delete from 表名 where 条件（例如：name=‘张三'，这里要注意单引号，在使用动态数据时不要忘了哦） 2.查询：select 字段1【如：Name】,字段2【如：gentle】 as '性别' from 表名 where 条件【如果字段用一个 * 代替，表示查询所有字段，where后可省略，将查询所有数据】 3添加：insert into 表名 (字段1,字段2...) values（对应值1，对应值2...）【这个不要where】 4.更新：update 表名 set 字段1=值1....where 条件【这个where必须，否则将更新所有行】 sqlcom.CommandString=“命令";// 下面要执行了打开链接：sqlconnect.open(); 执行：查询：DataReader dr=sqlcom.ExecuteReader();【dr！=null表示有值，读取成功】其他3个；int x=sqlcom.ExecuteNonQuery();【x!=-1表示操作成功】不要忘了！！！！ sqlconnect.Close（）；关闭数据库

怎么用c#的窗体对数据库进行增删该

C#操作Sql server2005 数据库，实现增删改查功能

数据库名 hospital

表名 office

字段 officeName(vachar(30)),officeType(vachar(30)),department(vachar(30))

代码：

using System;

using System.Drawing;

using System.Collections;

using System.ComponentModel;

using System.Windows.Forms;

using System.Data;

using System.Data.SqlClient;

namespace Test

{

/// <summary>

/// Form1 的摘要说明。

/// </summary>

public class Form1 : System.Windows.Forms.Form

{

//声明连接

private SqlConnection conn;

private System.Windows.Forms.Button button1;

private System.Windows.Forms.TextBox textBox1;

private System.Windows.Forms.TextBox textBox2;

private System.Windows.Forms.TextBox textBox3;

private System.Windows.Forms.Button button2;

private System.Windows.Forms.DataGrid dataGrid1;

private System.Windows.Forms.Button button4;

/// <summary>

/// 必需的设计器变量。

/// </summary>

private System.ComponentModel.Container components = null;

public Form1()

{

// Windows 窗体设计器支持所必需的

InitializeComponent();

// TODO: 在 InitializeComponent 调用后添加任何构造函数代码

}

/// <summary>

/// 清理所有正在使用的资源。

/// </summary>

protected override void Dispose( bool disposing )

{

if( disposing )

{

if (components != null)

{

components.Dispose();

}

base.Dispose( disposing );

}

#region Windows 窗体设计器生成的代码

/// <summary>

/// 设计器支持所需的方法 - 不要使用代码编辑器修改

/// 此方法的内容。

/// </summary>

private void InitializeComponent()

{

this.button1 = new System.Windows.Forms.Button();

this.textBox1 = new System.Windows.Forms.TextBox();

this.textBox2 = new System.Windows.Forms.TextBox();

this.textBox3 = new System.Windows.Forms.TextBox();

this.button2 = new System.Windows.Forms.Button();

this.dataGrid1 = new System.Windows.Forms.DataGrid();

this.button4 = new System.Windows.Forms.Button();

((System.ComponentModel.ISupportInitialize)(this.dataGrid1)).BeginInit();

this.SuspendLayout();

// button1

this.button1.Location = new System.Drawing.Point(56, 56);

this.button1.Name = "button1";

this.button1.TabIndex = 0;

this.button1.Text = "新增";

this.button1.Click += new System.EventHandler(this.button1_Click);

// textBox1

this.textBox1.Location = new System.Drawing.Point(152, 272);

this.textBox1.Name = "textBox1";

this.textBox1.Size = new System.Drawing.Size(120, 21);

this.textBox1.TabIndex = 2;

this.textBox1.Text = "";

// textBox2

this.textBox2.Location = new System.Drawing.Point(304, 272);

this.textBox2.Name = "textBox2";

this.textBox2.Size = new System.Drawing.Size(120, 21);

this.textBox2.TabIndex = 2;

this.textBox2.Text = "";

// textBox3

this.textBox3.Location = new System.Drawing.Point(464, 272);

this.textBox3.Name = "textBox3";

this.textBox3.Size = new System.Drawing.Size(120, 21);

this.textBox3.TabIndex = 2;

this.textBox3.Text = "";

// button2

this.button2.Location = new System.Drawing.Point(56, 104);

this.button2.Name = "button2";

this.button2.TabIndex = 0;

this.button2.Text = "修改";

this.button2.Click += new System.EventHandler(this.button2_Click);

// dataGrid1

this.dataGrid1.DataMember = "";

this.dataGrid1.HeaderForeColor = System.Drawing.SystemColors.ControlText;

this.dataGrid1.Location = new System.Drawing.Point(152, 16);

this.dataGrid1.Name = "dataGrid1";

this.dataGrid1.Size = new System.Drawing.Size(504, 248);

this.dataGrid1.TabIndex = 1;

this.dataGrid1.CurrentCellChanged += new System.EventHandler(this.dataGrid1_CurrentCellChanged_1);

// button4

this.button4.Location = new System.Drawing.Point(56, 152);

this.button4.Name = "button4";

this.button4.TabIndex = 0;

this.button4.Text = "删除";

this.button4.Click += new System.EventHandler(this.button4_Click);

// Form1

this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);

this.ClientSize = new System.Drawing.Size(664, 318);

this.Controls.Add(this.textBox1);

this.Controls.Add(this.button1);

this.Controls.Add(this.textBox2);

this.Controls.Add(this.textBox3);

this.Controls.Add(this.button2);

this.Controls.Add(this.dataGrid1);

this.Controls.Add(this.button4);

this.Name = "Form1";

this.Text = "Form1";

this.Load += new System.EventHandler(this.Form1_Load);

((System.ComponentModel.ISupportInitialize)(this.dataGrid1)).EndInit();

this.ResumeLayout(false);

}

#endregion

/// <summary>

/// 应用程序的主入口点。

/// </summary>

[STAThread]

static void Main()

{

Application.Run(new Form1());

}

private void btn_lj_Click(object sender, System.EventArgs e)

{

//连接串

string str="Server=(local);uid=sa;pwd=;database=hospital";

//连接

conn=new SqlConnection(str);

//sql

string sql="select officeName as 科室名称 ,officeType as 科别, "+

"department as 所属部门 from office ";

//适配器

SqlDataAdapter sqldap=new SqlDataAdapter(sql,this.conn);

//内存表

DataTable dt=new DataTable();

//填充

sqldap.Fill(dt);

//数据绑定

this.dataGrid1.DataSource=dt;

}

//刷新方法

public void myreflush()

{

string sql="select officeName as 科室名称 ,officeType as 科别, "+

"department as 所属部门 from office ";

SqlDataAdapter sqldap=new SqlDataAdapter(sql,this.conn);

DataTable dt=new DataTable();

sqldap.Fill(dt);

this.dataGrid1.DataSource=dt;

}

private void button1_Click(object sender, System.EventArgs e)

{

//新增

if(this.conn.State==ConnectionState.Closed)

{

this.conn.Open();

}

string sql="insert into office values('"+this.textBox1.Text+"','"+this.textBox2.Text+"','"+this.textBox3.Text+"')";

SqlCommand sqlcmd=new SqlCommand(sql,this.conn);

int i=sqlcmd.ExecuteNonQuery();

if(i!=0)

{

MessageBox.Show("Ok");

this.myreflush();

}

else

{

MessageBox.Show("No");

}

//连动

private void dataGrid1_CurrentCellChanged_1(object sender, System.EventArgs e)

{

//获取当前选择行数

int iCount=this.dataGrid1.CurrentCell.RowNumber;

//数据来源

DataTable dt=(DataTable)this.dataGrid1.DataSource;

try

{

this.textBox1.Text=Convert.ToString(dt.Rows[iCount]["科室名称"]);

this.textBox2.Text=Convert.ToString(dt.Rows[iCount]["科别"]);

this.textBox3.Text=Convert.ToString(dt.Rows[iCount]["所属部门"]);

}

catch(System.IndexOutOfRangeException)

{

MessageBox.Show("此行不存在");

}

private void Form1_Load(object sender, System.EventArgs e)

{

//连接串

string str="Server=(local);uid=sa;pwd=;database=hospital";

//连接

conn=new SqlConnection(str);

//sql

string sql="select officeName as 科室名称 ,officeType as 科别, "+

"department as 所属部门 from office ";

//适配器

SqlDataAdapter sqldap=new SqlDataAdapter(sql,this.conn);

//内存表

DataTable dt=new DataTable();

//填充

sqldap.Fill(dt);

//数据绑定

this.dataGrid1.DataSource=dt;

}

private void button4_Click(object sender, System.EventArgs e)

{

//删除

DialogResult dr=MessageBox.Show("是否真的删除"+this.textBox1.Text,"消息",MessageBoxButtons.OKCancel);

if(dr==DialogResult.OK)

{

if(this.conn.State==ConnectionState.Closed)

{

this.conn.Open();

}

string sql="delete from office where officeName='"+this.textBox1.Text+"'";

SqlCommand sqlcmd=new SqlCommand(sql,this.conn);

int i=sqlcmd.ExecuteNonQuery();

if(i!=0)

{

MessageBox.Show("OK");

}

else

{

MessageBox.Show("No");

}

this.myreflush();

}

private void button2_Click(object sender, System.EventArgs e)

{

//修改

if(this.conn.State==ConnectionState.Closed)

{

this.conn.Open();

}

string sql="update office set officeType='"+this.textBox2.Text+"',department='"+this.textBox3.Text+"'"

+"where officeName='"+this.textBox1.Text+"'";

SqlCommand sqlcmd=new SqlCommand(sql,this.conn);

int i=sqlcmd.ExecuteNonQuery();

if(i!=0)

{

MessageBox.Show("OK");

this.myreflush();

}

else

{

MessageBox.Show("No");

}

C#怎么实现对SQL数据库增删改查

考试估计你也没时间写DBHelper类了,
我简单描述一下，也有代码供你参考
//拼写SQL语句增加
string strSql = "insert 表名 (列名,列名,列名,列名)"
+" values ('{0}',{1},'{2}','{3}')";

strSql = string.Format(strSql, 文本框插入值,文本框插入值, 文本框插入值, 文本框插入值);

try
{
//创建 Command 对象
SqlCommand comm = new SqlCommand(strSql, conn);

//打开连接
conn.Open();

//执行命令
int iResult = comm.ExecuteNonQuery();

if (iResult != 1)
{
MessageBox.Show("添加失败！");
}
else
{
MessageBox.Show("添加成功！");
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
finally
{
conn.Close();
}

C#怎么实现对SQL数据库增删改查

简单的c#winform sql数据库的增删改查功能最好把代码和数据库都给我谢谢啦急！

整删改查都是sql语句不分Winform和 Web

下面的是你需要的我的表命叫 story

#region Method

/// <summary>

/// 增加一条数据

/// </summary>

public int Add(BW.Model.story model)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("insert into story(");

strSql.Append("title,contents,add_time)");

strSql.Append(" values (");

strSql.Append("@title,@contents,@add_time)");

strSql.Append(";select @@IDENTITY");

SqlParameter[] parameters = {

new SqlParameter("@title", SqlDbType.NVarChar,550),

new SqlParameter("@contents", SqlDbType.NVarChar),

new SqlParameter("@add_time", SqlDbType.DateTime)};

parameters[0].Value = model.title;

parameters[1].Value = model.contents;

parameters[2].Value = model.add_time;

object obj = DbHelperSQL.GetSingle(strSql.ToString(),parameters);

if (obj == null)

{

return 0;

}

else

{

return Convert.ToInt32(obj);

}

/// <summary>

/// 更新一条数据

/// </summary>

public bool Update(BW.Model.story model)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("update story set ");

strSql.Append("title=@title,");

strSql.Append("contents=@contents,");

strSql.Append("add_time=@add_time");

strSql.Append(" where id=@id");

SqlParameter[] parameters = {

new SqlParameter("@title", SqlDbType.NVarChar,550),

new SqlParameter("@contents", SqlDbType.NVarChar),

new SqlParameter("@add_time", SqlDbType.DateTime),

new SqlParameter("@id", SqlDbType.Int,4)};

parameters[0].Value = model.title;

parameters[1].Value = model.contents;

parameters[2].Value = model.add_time;

parameters[3].Value = model.id;

int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);

if (rows > 0)

{

return true;

}

else

{

return false;

}

/// <summary>

/// 删除一条数据

/// </summary>

public bool Delete(int id)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("delete from story ");

strSql.Append(" where id=@id");

SqlParameter[] parameters = {

new SqlParameter("@id", SqlDbType.Int,4)

};

parameters[0].Value = id;

int rows=DbHelperSQL.ExecuteSql(strSql.ToString(),parameters);

if (rows > 0)

{

return true;

}

else

{

return false;

}

/// <summary>

/// 批量删除数据

/// </summary>

public bool DeleteList(string idlist )

{

StringBuilder strSql=new StringBuilder();

strSql.Append("delete from story ");

strSql.Append(" where id in ("+idlist + ") ");

int rows=DbHelperSQL.ExecuteSql(strSql.ToString());

if (rows > 0)

{

return true;

}

else

{

return false;

}

/// <summary>

/// 得到一个对象实体

/// </summary>

public BW.Model.story GetModel(int id)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("select top 1 id,title,contents,add_time from story ");

strSql.Append(" where id=@id");

SqlParameter[] parameters = {

new SqlParameter("@id", SqlDbType.Int,4)

};

parameters[0].Value = id;

BW.Model.story model=new BW.Model.story();

DataSet ds=DbHelperSQL.Query(strSql.ToString(),parameters);

if(ds.Tables[0].Rows.Count>0)

{

if(ds.Tables[0].Rows[0]["id"]!=null && ds.Tables[0].Rows[0]["id"].ToString()!="")

{

model.id=int.Parse(ds.Tables[0].Rows[0]["id"].ToString());

}

if(ds.Tables[0].Rows[0]["title"]!=null && ds.Tables[0].Rows[0]["title"].ToString()!="")

{

model.title=ds.Tables[0].Rows[0]["title"].ToString();

}

if(ds.Tables[0].Rows[0]["contents"]!=null && ds.Tables[0].Rows[0]["contents"].ToString()!="")

{

model.contents=ds.Tables[0].Rows[0]["contents"].ToString();

}

if(ds.Tables[0].Rows[0]["add_time"]!=null && ds.Tables[0].Rows[0]["add_time"].ToString()!="")

{

model.add_time=DateTime.Parse(ds.Tables[0].Rows[0]["add_time"].ToString());

}

return model;

}

else

{

return null;

}

/// <summary>

/// 获得数据列表

/// </summary>

public DataSet GetList(string strWhere)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("select id,title,contents,add_time ");

strSql.Append(" FROM story ");

if(strWhere.Trim()!="")

{

strSql.Append(" where "+strWhere);

}

return DbHelperSQL.Query(strSql.ToString());

}

/// <summary>

/// 获得前几行数据

/// </summary>

public DataSet GetList(int Top,string strWhere,string filedOrder)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("select ");

if(Top>0)

{

strSql.Append(" top "+Top.ToString());

}

strSql.Append(" id,title,contents,add_time ");

strSql.Append(" FROM story ");

if(strWhere.Trim()!="")

{

strSql.Append(" where "+strWhere);

}

strSql.Append(" order by " + filedOrder);

return DbHelperSQL.Query(strSql.ToString());

}

/// <summary>

/// 获取记录总数

/// </summary>

public int GetRecordCount(string strWhere)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("select count(1) FROM story ");

if(strWhere.Trim()!="")

{

strSql.Append(" where "+strWhere);

}

object obj = DbHelperSQL.GetSingle(strSql.ToString());

if (obj == null)

{

return 0;

}

else

{

return Convert.ToInt32(obj);

}

/// <summary>

/// 分页获取数据列表

/// </summary>

public DataSet GetListByPage(string strWhere, string orderby, int startIndex, int endIndex)

{

StringBuilder strSql=new StringBuilder();

strSql.Append("SELECT * FROM ( ");

strSql.Append(" SELECT ROW_NUMBER() OVER (");

if (!string.IsNullOrEmpty(orderby.Trim()))

{

strSql.Append("order by T." + orderby );

}

else

{

strSql.Append("order by T.id desc");

}

strSql.Append(")AS Row, T.* from story T ");

if (!string.IsNullOrEmpty(strWhere.Trim()))

{

strSql.Append(" WHERE " + strWhere);

}

strSql.Append(" ) TT");

strSql.AppendFormat(" WHERE TT.Row between {0} and {1}", startIndex, endIndex);

return DbHelperSQL.Query(strSql.ToString());

}

/// <summary>

/// 分页获取数据列表

/// </summary>

public DataSet GetList(int PageSize,int PageIndex,string strWhere)

{

SqlParameter[] parameters = {

new SqlParameter("@tblName", SqlDbType.VarChar, 255),

new SqlParameter("@fldName", SqlDbType.VarChar, 255),

new SqlParameter("@PageSize", SqlDbType.Int),

new SqlParameter("@PageIndex", SqlDbType.Int),

new SqlParameter("@IsReCount", SqlDbType.Bit),

new SqlParameter("@OrderType", SqlDbType.Bit),

new SqlParameter("@strWhere", SqlDbType.VarChar,1000),

};

parameters[0].Value = "story";

parameters[1].Value = "id";

parameters[2].Value = PageSize;

parameters[3].Value = PageIndex;

parameters[4].Value = 0;

parameters[5].Value = 0;

parameters[6].Value = strWhere;

return DbHelperSQL.RunProcere("UP_GetRecordByPage",parameters,"ds");

}*/

#endregion Method

用c#实现对 SQL数据库的连接关闭,增删查改

public abstract class SqlHelper
{
//获取数据库连接字符串，其属于静态变量且只读，项目中所有文档可以直接使用，但不能修改
public static readonly string ConnectionStringLocalTransaction = ConfigurationManager.ConnectionStrings["pubsConnectionString"].ConnectionString;

// 哈希表用来存储缓存的参数信息，哈希表可以存储任意类型的参数。
private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable());

/// <summary>
///执行一个不需要返回值的SqlCommand命令，通过指定专用的连接字符串。
/// 使用参数数组形式提供参数列表
/// </summary>
/// <remarks>
/// 使用示例：
/// int result = ExecuteNonQuery(connString, CommandType.StoredProcere, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString">一个有效的数据库连接字符串</param>
/// <param name="commandType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="commandText">存储过程的名字或者 T-SQL 语句</param>
/// <param name="commandParameters">以数组形式提供SqlCommand命令中用到的参数列表</param>
/// <returns>返回一个数值表示此SqlCommand命令执行后影响的行数</returns>
public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{

SqlCommand cmd = new SqlCommand();

using (SqlConnection conn = new SqlConnection(connectionString))
{
//通过PrePareCommand方法将参数逐个加入到SqlCommand的参数集合中
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();

//清空SqlCommand中的参数列表
cmd.Parameters.Clear();
return val;
}
}

/// <summary>
///执行一条不返回结果的SqlCommand，通过一个已经存在的数据库连接
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例：
/// int result = ExecuteNonQuery(conn, CommandType.StoredProcere, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="conn">一个现有的数据库连接</param>
/// <param name="commandType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="commandText">存储过程的名字或者 T-SQL 语句</param>
/// <param name="commandParameters">以数组形式提供SqlCommand命令中用到的参数列表</param>
/// <returns>返回一个数值表示此SqlCommand命令执行后影响的行数</returns>
public static int ExecuteNonQuery(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{

SqlCommand cmd = new SqlCommand();

PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return val;
}

/// <summary>
/// 执行一条不返回结果的SqlCommand，通过一个已经存在的数据库事物处理
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例：
/// int result = ExecuteNonQuery(trans, CommandType.StoredProcere, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="trans">一个存在的 sql 事物处理</param>
/// <param name="commandType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="commandText">存储过程的名字或者 T-SQL 语句</param>
/// <param name="commandParameters">以数组形式提供SqlCommand命令中用到的参数列表</param>
/// <returns>返回一个数值表示此SqlCommand命令执行后影响的行数</returns>
public static int ExecuteNonQuery(SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, commandParameters);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return val;
}

/// <summary>
/// 执行一条返回结果集的SqlCommand命令，通过专用的连接字符串。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例：
/// SqlDataReader r = ExecuteReader(connString, CommandType.StoredProcere, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString">一个有效的数据库连接字符串</param>
/// <param name="commandType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="commandText">存储过程的名字或者 T-SQL 语句</param>
/// <param name="commandParameters">以数组形式提供SqlCommand命令中用到的参数列表</param>
/// <returns>返回一个包含结果的SqlDataReader</returns>
public static SqlDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();
SqlConnection conn = new SqlConnection(connectionString);

// 在这里使用try/catch处理是因为如果方法出现异常，则SqlDataReader就不存在，
//CommandBehavior.CloseConnection的语句就不会执行，触发的异常由catch捕获。
//关闭数据库连接，并通过throw再次引发捕捉到的异常。
try
{
PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters);
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return rdr;
}
catch
{
conn.Close();
throw;
}
}

/// <summary>
/// 执行一条返回第一条记录第一列的SqlCommand命令，通过专用的连接字符串。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例：
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcere, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="connectionString">一个有效的数据库连接字符串</param>
/// <param name="commandType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="commandText">存储过程的名字或者 T-SQL 语句</param>
/// <param name="commandParameters">以数组形式提供SqlCommand命令中用到的参数列表</param>
/// <returns>返回一个object类型的数据，可以通过 Convert.To{Type}方法转换类型</returns>
public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{
SqlCommand cmd = new SqlCommand();

using (SqlConnection connection = new SqlConnection(connectionString))
{
PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
object val = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return val;
}
}

/// <summary>
/// 执行一条返回第一条记录第一列的SqlCommand命令，通过已经存在的数据库连接。
/// 使用参数数组提供参数
/// </summary>
/// <remarks>
/// 使用示例：
/// Object obj = ExecuteScalar(connString, CommandType.StoredProcere, "PublishOrders", new SqlParameter("@prodid", 24));
/// </remarks>
/// <param name="conn">一个已经存在的数据库连接</param>
/// <param name="commandType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="commandText">存储过程的名字或者 T-SQL 语句</param>
/// <param name="commandParameters">以数组形式提供SqlCommand命令中用到的参数列表</param>
/// <returns>返回一个object类型的数据，可以通过 Convert.To{Type}方法转换类型</returns>
public static object ExecuteScalar(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters)
{

SqlCommand cmd = new SqlCommand();

PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters);
object val = cmd.ExecuteScalar();
cmd.Parameters.Clear();
return val;
}

/// <summary>
/// 缓存参数数组
/// </summary>
/// <param name="cacheKey">参数缓存的键值</param>
/// <param name="cmdParms">被缓存的参数列表</param>
public static void CacheParameters(string cacheKey, params SqlParameter[] commandParameters)
{
parmCache[cacheKey] = commandParameters;
}

/// <summary>
/// 获取被缓存的参数
/// </summary>
/// <param name="cacheKey">用于查找参数的KEY值</param>
/// <returns>返回缓存的参数数组</returns>
public static SqlParameter[] GetCachedParameters(string cacheKey)
{
SqlParameter[] cachedParms = (SqlParameter[])parmCache[cacheKey];

if (cachedParms == null)
return null;

//新建一个参数的克隆列表
SqlParameter[] clonedParms = new SqlParameter[cachedParms.Length];

//通过循环为克隆参数列表赋值
for (int i = 0, j = cachedParms.Length; i < j; i++)
//使用clone方法复制参数列表中的参数
clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone();

return clonedParms;
}

/// <summary>
/// 为执行命令准备参数
/// </summary>
/// <param name="cmd">SqlCommand 命令</param>
/// <param name="conn">已经存在的数据库连接</param>
/// <param name="trans">数据库事物处理</param>
/// <param name="cmdType">SqlCommand命令类型 (存储过程， T-SQL语句，等等。)</param>
/// <param name="cmdText">Command text，T-SQL语句例如 Select * from Procts</param>
/// <param name="cmdParms">返回带参数的命令</param>
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms)
{

//判断数据库连接状态
if (conn.State != ConnectionState.Open)
conn.Open();

cmd.Connection = conn;
cmd.CommandText = cmdText;

//判断是否需要事物处理
if (trans != null)
cmd.Transaction = trans;

cmd.CommandType = cmdType;

if (cmdParms != null)
{
foreach (SqlParameter parm in cmdParms)
cmd.Parameters.Add(parm);
}
}

用c#实现对 SQL数据库的连接关闭,增删查改

C#窗体实现SQL的增删改查功能

into dbo.人员管理 values (‘符显耀‘, ‘xiany.fu‘, 23) --增加
　　　insert into dbo.人员管理 values(‘曾嘉年‘, ‘jn.zeng‘, 23)

技术分享

增加两行

3、SQL UPDATE 语句(改)
　　Update 语句用于修改表中的数据。
　　语法：(更新哪个表，设置某列=新值在列=某值处)
　　　　UPDATE 表名称 SET 列名称 = 新值 WHERE 列名称 = 某值

　　　update dbo.人员管理 set 姓名=‘王小耀‘ where 姓名=‘符显耀‘ --修改

技术分享

更改

4、SQL DELETE 语句(删)
　　DELETE 语句用于删除表中的行。
　　语法:(从表中删除列名称=值的行)
　　　　DELETE FROM 表名称 WHERE 列名称 = 值
　　　　DELETE FROM 表名称--删除表中的所有行

　　　delete from dbo.人员管理 where 姓名=‘曾嘉年‘ --删除

技术分享

删除

5、SQL SELECT 语句(查)
　　　SELECT 语句用于从表中选取数据。结果被存储在一个结果表中（称为结果集）。
　　语法:(选出哪些列从表中)
　　　　SELECT 列名称 FROM 表名称
　　　　SELECT * FROM 表名称 --选出所有列从表中

　　　select * from dbo.人员管理 --查找

SQL基础教程--实现增删查改功能(W3School)

标签：

C#窗体实现SQL的增删改查功能

into dbo.人员管理 values (‘符显耀‘, ‘xiany.fu‘, 23) --增加
　　　insert into dbo.人员管理 values(‘曾嘉年‘, ‘jn.zeng‘, 23)

技术分享

增加两行

　　　update dbo.人员管理 set 姓名=‘王小耀‘ where 姓名=‘符显耀‘ --修改

技术分享

更改

　　　delete from dbo.人员管理 where 姓名=‘曾嘉年‘ --删除

技术分享

删除

　　　select * from dbo.人员管理 --查找

SQL基础教程--实现增删查改功能(W3School)

标签：

求C#winform 数据库类（连接和增删改查）和在窗口中的调用代码

C# 中分为三层，在数据访问层中写增删查改的代码和专门连接数据库的一个类写Connection；在窗口中调用的代码一般写在表示层。

新手求教，B/S模式，用C#实现对SQL的连接并实现增删改查，求代码

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data.SqlClient;

using System.Data;

namespace NewClient

{

class DBHelper

{

static string str = "data source=.;initial catalog=你的数据库名;integrated security=true";

public SqlConnection con = new SqlConnection(str);

/// <summary>

/// 查询单个值

/// </summary>

/// <param name="sql"></param>

/// <returns></returns>

public object Scalar(string sql)

{

object o = null;

try

{

con.Open();

SqlCommand cmd = new SqlCommand(sql, con);

o = cmd.ExecuteScalar();

}

catch (Exception)

{

throw;

}

finally

{

con.Close();

}

return o;

}

/// <summary>

/// 查询多个值

/// </summary>

/// <param name="sql"></param>

/// <returns></returns>

public SqlDataReader Reader(string sql)

{

SqlDataReader o = null;

try

{

con.Open();

SqlCommand cmd = new SqlCommand(sql, con);

o = cmd.ExecuteReader(CommandBehavior.CloseConnection);

}

catch (Exception)

{

throw;

}

return o;

}

/// <summary>

/// 增删改

/// </summary>

/// <param name="sql"></param>

/// <returns></returns>

public int NonQuery(string sql)

{

int o = -1;

try

{

con.Open();

SqlCommand cmd = new SqlCommand(sql, con);

o = cmd.ExecuteNonQuery();

}

catch (Exception)

{

throw;

}

finally

{

con.Close();

}

return o;

}

显示全文

全部栏目

C# 对SqlServer数据库增删改查