分享

.net使用中sqlcommand的用法

 pitt图书 2017-07-03

SqlCommand()方法


SqlCommand cmd = new SqlCommand("insert into mynews value ('插入一条新数据')", con);   
 Command对象的构造函数的参数有两个,一个是需要执行的SQL语句,另一个是数据库连接对象。创建Command对象后,就可以执行SQL命令,执行后完成并关闭数据连接,示例代码如下所示。
cmd.ExecuteNonQuery(); //执行SQL命令
con.Close(); //关闭连接
 
SqlCommand类的属性
 
1.CommandText  
 获取或设置要对数据源执行的Transact—SQL语句或存储过程的名称。
 
2. CommandType  
获取或设置一个值,该值指示如何解释CommandText属性。

当将 CommandType 属性设置为 StoredProcedure 时,应将 CommandText 属性设置为存储过程的名称。当调用 Execute 方法之一时,该命令将执行此存储过程。

用于 SQL Server 的 Microsoft .NET Framework 数据提供程序不支持在向通过 TextCommandType 调用的 SQL 语句或存储过程传递参数时使用问号 (?) 占位符。在这种情况下,必须使用命名的参数。例如:

SELECT * FROM Customers WHERE CustomerID = @CustomerID

 

下面的示例创建一个SqlCommand并设置它的一些属性。

  1. public void CreateSqlCommand()  
  2. {  
  3.           SqlCommand command = new SqlCommand();  
  4.           command.CommandTimeout = 15;  
  5.           command.CommandType = CommandType.Text;  
  6. }  

 
3.Connection 
获取或设置SqlCommand的实例使用的SqlConnection。
 
4.CommandTimeOut   
获取或设置在终止执行命令的尝试并生成错误之前的等待时间。

 

 

SqlCommand类的方法
 
1.ExecuteNonQuery();  
 它的返回值类型为int型。多用于执行增加,删除,修改数据。返回受影响的行数。当select操作时,返回-1。
 
2.ExecuteReader();  
  它的返回类型为SqlDataReader。此方法用于用户进行的查询操作。使用SqlDataReader对象的Read();方法进行逐行读取。
例如:

  1. SqlCommand comm =new SqlCommand("select * from CGSZ where cid="+id,conn);    
  2. SqlDataReader reder=comm.ExecuteReader();   
  3. while(reder.Read())   
  4. {    
  5.           //读出内容列  
  6.           string str=reder["cname"].ToString();   
  7.          //读取分类列  
  8.          string str1=reder["ckind"].ToString();   
  9.           //分别为文本框加载数据  
  10.          this.txtContent.Text = str;    
  11.          this.txtClass.Text = str1;     
  12. }  
  1. /// <summary>  
  2. /// 对连接执行 Transact-SQL 语句返回一个SqlDataReader,查询是否存在记录(注意要关闭)。  
  3. /// </summary>  
  4. /// <param name="sql"></param>  
  5. /// <returns></returns>  
  6. public static SqlDataReader GetReader(string sql)  
  7. {  
  8.     using (SqlConnection con = new SqlConnection(ConnectionString))  
  9.     {  
  10.         SqlCommand cmd = new SqlCommand(sql,con);  
  11.         con.Open();  
  12.         SqlDataReader reader = cmd.ExecuteReader();  
  13.         return reader;  
  14.     }  
  15. }  

其中的读取数据列的时候。除了使用reder["列名"].ToString();还可以使用reder[索引].ToSting();<注意:这里的索引指的是数据库中列的索引。从0开始。> 

 

3.ExecuteScaler();  
 它的返回值类型多位int类型。它返回的多为执行select查询。得到的返回结果为一个值的情况,比如使用count函数求表中记录个数或者使用sum函数求和等。

  1. /// <summary>  
  2. /// Update(// || p.Value.ToString().Trim() == "System.Byte[]")) by richmen 2011 05  
  3. /// 注释掉才可以实现相片的修改跟保存功能  
  4. /// 执行查询,并返回查询所返回的结果集中第一行的第一列。忽略其他列或行。  
  5. /// </summary>  
  6. /// <param name="sql">sql语句或者存储过程的名称</param>  
  7. /// <param name="parameters">null的时候为sql</param>  
  8. /// <returns></returns>  
  9. public static object ExecuteScalar(string sql, SqlParameter[] parameters)  
  10. {  
  11.     if (parameters != null)  
  12.     {  
  13.         foreach (SqlParameter p in parameters)  
  14.         {  
  15.             if (p.Value == null)// || p.Value.ToString().Trim() == "System.Byte[]")  
  16.                 p.Value = DBNull.Value;  
  17.         }  
  18.     }  
  19.     using (SqlConnection con = new SqlConnection(ConnectionString))  
  20.     {  
  21.         SqlCommand cmd = new SqlCommand();  
  22.         cmd.Connection = con;  
  23.         if (parameters != null)  
  24.         {  
  25.             cmd.CommandType = CommandType.StoredProcedure;  
  26.             cmd.Parameters.AddRange(parameters);  
  27.         }  
  28.         else  
  29.         {  
  30.             cmd.CommandType = CommandType.Text;  
  31.         }  
  32.         cmd.CommandText = sql;  
  33.         try  
  34.         {  
  35.             con.Open();  
  36.             return cmd.ExecuteScalar();  
  37.         }  
  38.         catch  
  39.         {  
  40.             return string.Empty;  
  41.         }  
  42.     }  
  43. }  
  44. }  

4.其它;  
当参数中含有问号 (?) 等占位符时,必须使用命名的参数。

下面的示例演示如何创建 SqlCommand 和向 SqlParameterCollection 中添加参数。例如:

  1. private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, string cmdText, SqlParameter[] cmdParms)  
  2.         {  
  3.             if (conn.State != ConnectionState.Open)  
  4.             {  
  5.                 conn.Open();  
  6.             }  
  7.             cmd.Connection = conn;  
  8.             cmd.CommandText = cmdText;  
  9.             if (trans != null)  
  10.             {  
  11.                 cmd.Transaction = trans;  
  12.             }  
  13.             cmd.CommandType = CommandType.Text;  
  14.             if (cmdParms != null)  
  15.             {  
  16.                 for (int i = 0; i < cmdParms.Length; i++)  
  17.                 {  
  18.                     SqlParameter sqlParameter = cmdParms[i];  
  19.                     if ((sqlParameter.Direction == ParameterDirection.InputOutput || sqlParameter.Direction == ParameterDirection.Input) && sqlParameter.Value == null)  
  20.                     {  
  21.                         sqlParameter.Value = DBNull.Value;  
  22.                     }  
  23.                     cmd.Parameters.Add(sqlParameter);  
  24.                 }  
  25.             }  
  26.         }  
  1. private static void UpdateDemographics(Int32 customerID,string demoXml, string connectionString)  
  2. {  
  3.     // Update the demographics for a store, which is stored   
  4.     // in an xml column.   
  5.     string commandText = "UPDATE Sales.Store SET Demographics = @demographics "  
  6.         + "WHERE CustomerID = @ID;";  
  7.   
  8.     using (SqlConnection connection = new SqlConnection(connectionString))  
  9.     {  
  10.         SqlCommand command = new SqlCommand(commandText, connection);  
  11.         command.Parameters.Add("@ID", SqlDbType.Int);  
  12.         command.Parameters["@ID"].Value = customerID;  
  13.   
  14.         // Use AddWithValue to assign Demographics.  
  15.         // SQL Server will implicitly convert strings into XML.  
  16.         command.Parameters.AddWithValue("@demographics", demoXml);  
  17.   
  18.         try  
  19.         {  
  20.             connection.Open();  
  21.             Int32 rowsAffected = command.ExecuteNonQuery();  
  22.             Console.WriteLine("RowsAffected: {0}", rowsAffected);  
  23.         }  
  24.         catch (Exception ex)  
  25.         {  
  26.             Console.WriteLine(ex.Message);  
  27.         }  
  28.     }  
  29. }  


    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多