百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

168.C# Command对象(c#compute)

zhezhongyun 2025-03-19 18:37 18 浏览

摘要


使用Connection对象与数据源建∥.连接后,可以使用Command对象对数据源执行查询、添加、删除利和修收等各种操作,操作实现的方可以是使用SQL语句,也可以是使用存储过程。根据.NET Framework数据提供程序的不同Command对象可以分成4种,分别是SqlCommand、OleDbCommand、OdbcCommand和DracleCommand,在实际的编程过程中应该根据访问的数据源不同,选择相对应的Command对象。

正文


属性



CommandText

获取或设置要在数据源中执行的 Transact-SQL 语句、表名或存储过程。

CommandTimeout

获取或设置在终止尝试执行命令并生成错误之前的等待时间(以秒为单位)。

CommandType

获取或设置一个值,该值指示解释 CommandText 属性的方式。

Connection

获取或设置 SqlCommand 的此实例使用的 SqlConnection。

DbConnection

获取或设置此 DbConnection 使用的 DbCommand。

(继承自 DbCommand)

DbParameterCollection

获取 DbParameter 对象的集合。

(继承自 DbCommand)

DbTransaction

获取或设置将在其中执行此 DbCommand 对象的 DbTransaction。

(继承自 DbCommand)

DesignTimeVisible

获取或设置一个值,该值指示命令对象是否应在 Windows 窗体设计器控件中可见。

Notification

获取或设置一个指定绑定到此命令的 SqlNotificationRequest 对象的值。

Parameters

获取 SqlParameterCollection。

Transaction

获取或设置要在其中执行 SqlTransaction 的 SqlCommand。

UpdatedRowSource

获取或设置命令结果如何应用于 DataRow Update 方法 DbDataAdapter的用法。

方法



BeginExecuteNonQuery()

启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行。

BeginExecuteNonQuery(AsyncCallback, Object)

在给定回调过程和状态信息的情况下,启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行。

BeginExecuteReader()

启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行,并从服务器中检索一个或多个结果集。

BeginExecuteReader(AsyncCallback, Object)

在给定回调过程和状态信息的情况下,启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行,并从服务器中检索一个或多个结果集。

BeginExecuteReader(AsyncCallback, Object, CommandBehavior)

在给定回调过程和状态信息的情况下,通过使用 CommandBehavior 值之一并从服务器中检索一个或多个结果集,启动由此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行。

BeginExecuteReader(CommandBehavior)

通过使用 CommandBehavior 值之一,启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行。

BeginExecuteXmlReader()

启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行,并将结果作为 XmlReader 对象返回。

BeginExecuteXmlReader(AsyncCallback, Object)

通过使用回调过程,启动此 SqlCommand 描述的 Transact-SQL 语句或存储过程的异步执行,并将结果作为 XmlReader 对象返回。

Cancel()

尝试取消 SqlCommand 的执行。

CreateDbParameter()

创建 DbParameter 对象的新实例。

(继承自 DbCommand)

CreateParameter()

创建 SqlParameter 对象的新实例。

EndExecuteNonQuery(IAsyncResult)

完成 Transact-SQL 语句的异步执行。

EndExecuteReader(IAsyncResult)

完成 Transact-SQL 语句的异步执行,从而返回请求的 SqlDataReader。

EndExecuteXmlReader(IAsyncResult)

完成 Transact-SQL 语句的异步执行,从而将请求的数据以 XML 形式返回。

ExecuteDbDataReader(CommandBehavior)

针对其连接执行命令,返回可用于访问结果的命令 DbDataReader 。

(继承自 DbCommand)

ExecuteDbDataReaderAsync(CommandBehavior, CancellationToken)

提供程序应执行该方法对 ExecuteReader 重载提供非默认的实现。

默认实现调用同步 ExecuteReader() 方法并返回已完成任务,以便阻止调用线程。 如果传递到已取消的取消标记,则默认实现将返回已取消的任务。 ExecuteReader 引发的异常将通过返回的任务异常属性传递。

该方法可用于请求操作之前接受取消标记。 实现可能会忽略该请求。

(继承自 DbCommand)

ExecuteNonQuery()

对连接执行 Transact-SQL 语句并返回受影响的行数。

ExecuteNonQueryAsync()

一个异步版本 ExecuteNonQuery(),它对其连接对象执行命令,返回受影响的行数。

通过 CancellationToken.None 调用 ExecuteNonQueryAsync(CancellationToken)。

(继承自 DbCommand)

ExecuteNonQueryAsync(CancellationToken)

异步版本,该版本ExecuteNonQuery()针对连接执行 Transact-SQL 语句,并返回受影响的行数。 取消标记可用于在命令超时超过前请求放弃操作。 将通过返回的任务对象报告异常。

ExecuteReader()

将 CommandText 发送到 Connection,并生成 SqlDataReader。

ExecuteReader(CommandBehavior)

将 CommandText 发送到 Connection,并使用 CommandBehavior 值之一生成 SqlDataReader。

ExecuteReaderAsync()

ExecuteReader() 的异步版本,它可以将 CommandText 发送到 Connection,并生成 SqlDataReader。 将通过返回的任务对象报告异常。

ExecuteReaderAsync(CancellationToken)

ExecuteReader() 的异步版本,它可以将 CommandText 发送到 Connection,并生成 SqlDataReader。

取消标记可用于在命令超时超过前请求放弃操作。 将通过返回的任务对象报告异常。

ExecuteReaderAsync(CommandBehavior)

ExecuteReader(CommandBehavior) 的异步版本,用于将 CommandText 发送到 Connection,并生成一个 SqlDataReader。 将通过返回的任务对象报告异常。

ExecuteReaderAsync(CommandBehavior, CancellationToken)

ExecuteReader(CommandBehavior) 的异步版本,它可以将 CommandText 发送到 Connection,并生成 SqlDataReader。

取消标记可用于在命令超时超过前请求放弃操作。 将通过返回的任务对象报告异常。

ExecuteScalar()

执行查询,并返回查询所返回的结果集中第一行的第一列。 忽略其他列或行。

ExecuteScalarAsync()

异步版本的 ExecuteScalar()命令执行该命令,并返回第一个返回结果集中第一行的第一列。 将忽略所有其他列、行和结果集。

通过 CancellationToken.None 调用 ExecuteScalarAsync(CancellationToken)。

(继承自 DbCommand)

ExecuteScalarAsync(CancellationToken)

ExecuteScalar() 的异步版本,该版本异步执行查询,并返回由查询返回的结果集中的第一行的第一列。 忽略其他列或行。

取消标记可用于在命令超时超过前请求放弃操作。 将通过返回的任务对象报告异常。

ExecuteXmlReader()

将 CommandText 发送到 Connection,并生成一个 XmlReader 对象。

ExecuteXmlReaderAsync()

ExecuteXmlReader() 的异步版本,可以将 CommandText 发送到 Connection,并生成 XmlReader 对象。

将通过返回的任务对象报告异常。

ExecuteXmlReaderAsync(CancellationToken)

ExecuteXmlReader() 的异步版本,可以将 CommandText 发送到 Connection,并生成 XmlReader 对象。

取消标记可用于在命令超时超过前请求放弃操作。 将通过返回的任务对象报告异常。

ResetCommandTimeout()

将 CommandTimeout 属性重置为其默认值。

Command对象也称为数据库命令对象,Command对象主要执行包括添加、删除、修改及查询数据的操作的命令。也可以用来执行存储过程。用于执行存储过程时需要将Command对象的CommandType 属性设置为
CommandType.StoredProcedure,默认情况下CommandType 属性为CommandType.Text,表示执行的是普通SQL语句。Command主要有三个方法:

  • ExecuteNonQuery
  • ExecuteScalar
  • ExecuteReader

ExecuteNonQuery():执行一个SQL语句,返回受影响的行数,这个方法主要用于执行对数据库执行增加、更新、删除操作,注意查询的时候不是调用这个方法。用于完成insert,delete,update操作。

string sql = "INSERT  INTO wms_material(material_no, mlfb, description, repair_type, location" +
    ", actual_qty, qty, notification_no,urequestid) VALUES ('" + txtMaterialNo.Text + "','" + txtMlfb.Text
    + "','" + txtDescription.Text + "','" + cboRepairType.Text + "','" + txtLocation.Text
    + "'," + nudActualQty.Value + "," + nudQty.Value + ",'" + txtNotificationNo.Text + "','" + Guid.NewGuid().ToString() + "')";
SqlCommand cmd = new SqlCommand(sql, conn);
int rows = cmd.ExecuteNonQuery();
if (rows > 0)
{
    MessageBox.Show("保存数据成功!");
    this.Close();
}
else
{
    MessageBox.Show("保存数据出错!");
}

使用SqlParameter参数

string sql = "update wms_material set material_no=@material_no, mlfb=@mlfb,description=@description,repair_type=@repair_type" +
   ",location=@location,actual_qty=@actual_qty,qty=@qty,notification_no=@notification_no where id=@id";
SqlTransaction transaction = conn.BeginTransaction();
SqlCommand sqlcom = new SqlCommand(sql, conn);
try
{
    sqlcom.Transaction = transaction;
    sqlcom.Parameters.Add(new SqlParameter("@material_no", txtMaterialNo.Text));
    sqlcom.Parameters.Add(new SqlParameter("@mlfb", txtMlfb.Text));
    sqlcom.Parameters.Add(new SqlParameter("@description", txtDescription.Text));
    sqlcom.Parameters.Add(new SqlParameter("@repair_type", cboRepairType.Text));
    sqlcom.Parameters.Add(new SqlParameter("@location", txtLocation.Text));
    sqlcom.Parameters.Add(new SqlParameter("@actual_qty", nudActualQty.Text));
    sqlcom.Parameters.Add(new SqlParameter("@qty", nudQty.Text));
    sqlcom.Parameters.Add(new SqlParameter("@notification_no", txtNotificationNo.Text));
    sqlcom.Parameters.Add(new SqlParameter("@id", id));
    sqlcom.ExecuteNonQuery();
    transaction.Commit();
    MessageBox.Show("保存数据成功!");
    this.Close();
}
catch
{
    transaction.Rollback();
    MessageBox.Show("保存数据出错!");
}

删除

SqlCommand command = new SqlCommand();
command.Connection = connection;
command.CommandType = CommandType.StoredProcedure;
command.CommandText = "sp_delete_material";
command.Parameters.Add(new SqlParameter("@id", id));
command.ExecuteNonQuery();

ExecuteScalar ()从数据库检索单个值。这个方法主要用于统计操作。ExecuteScalar ()这个方法是针对SQL语句执行的结果是一行一列的结果集,这个方法只返回查询结果集的第一行第一列。 executeScalar主要用于查询单行单列的值,如聚合函数(count,max,min,agv,sum)。

string sql = "select count(*) from wms_material where material_no='" + txtMaterialNo.Text + "'";
SqlCommand cmd = new SqlCommand(sql, conn);
var ret = int.Parse(cmd.ExecuteScalar().ToString());

ExecuteReader用于实现只进只读的高效数据查询。 ExecuteReader:返回一个SqlDataReader对象,可以通过这个对象来检查查询结果,它提供了只进只读的执行方式,即从结果中读取一行之后,移动到另一行,则前一行就无法再用。有一点要注意的是执行之后,要等到手动去调用Read()方法之后,DataReader对象才会移动到结果集的第一行,同时此方法也返回一个Bool值,表明下一行是否可用,返回True则可用,返回False则到达结果集末尾。

string sql = "select * from wms_material where mlfb like '%" + txtSearch.Text + "%'";
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(sql, connection);
SqlDataReader sr = cmd.ExecuteReader();
while (sr.Read())
{
    ListViewItem item = new ListViewItem(sr["material_no"].ToString());
    item.SubItems.Add(sr["mlfb"].ToString());
    item.SubItems.Add(sr["repair_type"].ToString());
    item.SubItems.Add(sr["location"].ToString());
    item.SubItems.Add(sr["qty"].ToString());
    item.SubItems.Add(sr["actual_qty"].ToString());
    item.SubItems.Add(sr["description"].ToString());
    lsvMain.Items.Add(item);
}
sr.Close();

相关推荐

JPA实体类注解,看这篇就全会了

基本注解@Entity标注于实体类声明语句之前,指出该Java类为实体类,将映射到指定的数据库表。name(可选):实体名称。缺省为实体类的非限定名称。该名称用于引用查询中的实体。不与@Tab...

Dify教程02 - Dify+Deepseek零代码赋能,普通人也能开发AI应用

开始今天的教程之前,先解决昨天遇到的一个问题,docker安装Dify的时候有个报错,进入Dify面板的时候会出现“InternalServerError”的提示,log日志报错:S3_USE_A...

用离散标记重塑人体姿态:VQ-VAE实现关键点组合关系编码

在人体姿态估计领域,传统方法通常将关键点作为基本处理单元,这些关键点在人体骨架结构上代表关节位置(如肘部、膝盖和头部)的空间坐标。现有模型对这些关键点的预测主要采用两种范式:直接通过坐标回归或间接通过...

B 客户端流RPC (clientstream Client Stream)

客户端编写一系列消息并将其发送到服务器,同样使用提供的流。一旦客户端写完消息,它就等待服务器读取消息并返回响应gRPC再次保证了单个RPC调用中的消息排序在客户端流RPC模式中,客户端会发送多个请...

我的模型我做主02——训练自己的大模型:简易入门指南

模型训练往往需要较高的配置,为了满足友友们的好奇心,这里我们不要内存,不要gpu,用最简单的方式,让大家感受一下什么是模型训练。基于你的硬件配置,我们可以设计一个完全在CPU上运行的简易模型训练方案。...

开源项目MessageNest打造个性化消息推送平台多种通知方式

今天介绍一个开源项目,MessageNest-可以打造个性化消息推送平台,整合邮件、钉钉、企业微信等多种通知方式。定制你的消息,让通知方式更灵活多样。开源地址:https://github.c...

使用投机规则API加快页面加载速度

当今的网络用户要求快速导航,从一个页面移动到另一个页面时应尽量减少延迟。投机规则应用程序接口(SpeculationRulesAPI)的出现改变了网络应用程序接口(WebAPI)领域的游戏规则。...

JSONP安全攻防技术

关于JSONPJSONP全称是JSONwithPadding,是基于JSON格式的为解决跨域请求资源而产生的解决方案。它的基本原理是利用HTML的元素标签,远程调用JSON文件来实现数据传递。如果...

大数据Doris(六):编译 Doris遇到的问题

编译Doris遇到的问题一、js_generator.cc:(.text+0xfc3c):undefinedreferenceto`well_known_types_js’查找Doris...

网页内嵌PDF获取的办法

最近女王大人为了通过某认证考试,交了2000RMB,官方居然没有给线下教材资料,直接给的是在线教材,教材是PDF的但是是内嵌在网页内,可惜却没有给具体的PDF地址,无法下载,看到女王大人一点点的截图保...

印度女孩被邻居家客人性骚扰,父亲上门警告,反被围殴致死

微信的规则进行了调整希望大家看完故事多点“在看”,喜欢的话也点个分享和赞这样事儿君的推送才能继续出现在你的订阅列表里才能继续跟大家分享每个开怀大笑或拍案惊奇的好故事啦~话说只要稍微关注新闻的人,应该...

下周重要财经数据日程一览 (1229-0103)

下周焦点全球制造业PMI美国消费者信心指数美国首申失业救济人数值得注意的是,下周一希腊还将举行第三轮总统选举需要谷歌日历同步及部分智能手机(安卓,iPhone)同步日历功能的朋友请点击此链接,数据公布...

PyTorch 深度学习实战(38):注意力机制全面解析

在上一篇文章中,我们探讨了分布式训练实战。本文将深入解析注意力机制的完整发展历程,从最初的Seq2Seq模型到革命性的Transformer架构。我们将使用PyTorch实现2个关键阶段的注意力机制变...

聊聊Spring AI的EmbeddingModel

序本文主要研究一下SpringAI的EmbeddingModelEmbeddingModelspring-ai-core/src/main/java/org/springframework/ai/e...

前端分享-少年了解过iframe么

iframe就像是HTML的「内嵌画布」,允许在页面中加载独立网页,如同在画布上叠加另一幅动态画卷。核心特性包括:独立上下文:每个iframe都拥有独立的DOM/CSS/JS环境(类似浏...