2 u010384336 u010384336 于 2016.04.07 18:51 提问

C#连接mysql然后查询存储过程

C#连接mysql 然后查询一个名为userinfo的存储过程,传参5

sql:call userinfo(5);

这个是查询用户的信息的存储过程,执行这个sql,然后获得查询出来的结果,并且输出。

有没有大神写个demo我学习一下,谢谢!

//正常执行sql语句我会,不会查存储过程

2个回答

CSDNXIAOD
CSDNXIAOD   2016.04.07 19:02
已采纳

C#调用mysql查询存储过程
c#连接mysql 找不到存储过程
mysql 树形结构查询(存储过程)
----------------------biu~biu~biu~~~在下问答机器人小D,这是我依靠自己的聪明才智给出的答案,如果不正确,你来咬我啊!

caozhy
caozhy   Ds   Rxr 2016.04.08 04:58
 using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using MySql.Data.MySqlClient;
using System.ComponentModel;
using System.Drawing;
using System.Windows.Forms;
using System.Diagnostics;

//*************************** 
//* * 功 能: 查询,添加,更新,删除,集数调用储存过程的封装,
//* * 创 建 人:*****
//* * 创 建 日 期:2013-8-10 11:30:30  
//* * 状 态:********
//* * 完 成 日 期:******
//* * 修 改 人: *****
//* * 修 改 日 期:   *****
//* * 修 改 内 容:****
//* * 备 注 描 述:    ********       
//***************************

namespace KFTV.DB
{
   public  class BaseDB
    {
      static string strcon = KFTV.Properties.Settings.Default.kftvConnectionString;
       ///
       /// 查询的储存过程调用
       ///
       /// 储存过程名
       /// 查询条件的数组参数
       ///
       public static DataSet RunProcedureForQuery(string storedProcName, IDataParameter[] parameteres)
       {
           using (MySqlConnection conn = new MySqlConnection(strcon))
           {
               DataSet ds = new DataSet();
               try
               {
                   conn.Open();
                   MySqlCommand cm = new MySqlCommand();
                   cm.Connection = conn;
                   cm.CommandText = storedProcName;
                   cm.CommandType = CommandType.StoredProcedure;
                   cm.Parameters.AddRange(parameteres);
                   MySqlDataAdapter adapter = new MySqlDataAdapter(cm);
                   adapter.Fill(ds);
                   conn.Close();
                   return ds;
               }
               catch
               {
                   if (MessageBox.Show("执行出错了!\n\r可能服务器不稳定!\n\r请关闭后重试!", "提示", MessageBoxButtons.YesNo) == DialogResult.Yes)
                   {
                       Application.Exit();
                   }
                   return null;
               }
           } 
       }
       ///
       /// 更新,添加,删除的储存过程调用
       ///
       /// 储存过程名
       /// 更新,添加,删除所需参数
       ///
       public static int RunProcedureForNonQuery(string storedProcName, IDataParameter[] parameteres)
       {
           using (MySqlConnection conn = new MySqlConnection(strcon))
           {
               int rowsAffected = 0;
               try
               {
                   conn.Open();
                   MySqlCommand cm = new MySqlCommand();
                   cm.Connection = conn;
                   cm.CommandText = storedProcName;
                   cm.CommandType = CommandType.StoredProcedure;
                   cm.Parameters.AddRange(parameteres);
                   rowsAffected = cm.ExecuteNonQuery();
                   conn.Close();
               }
               catch 
               {
                   if (MessageBox.Show("执行出错了!\n\r可能服务器不稳定!\n\r请关闭后重试!", "提示", MessageBoxButtons.YesNo) == DialogResult.Yes)
                   {
                       Application.Exit();
                   }
               }
               return rowsAffected;
           }
       }
       ///
       /// 求符合条件的总个数
       ///
       /// 储存过程名
       ///
       public static int RunProcedureForScaler(string storedProcName)
       {
           using (MySqlConnection conn = new MySqlConnection(strcon))
           {
               int sum = 0;
               try
               {
                   conn.Open();
                   MySqlCommand cm = new MySqlCommand();
                   cm.Connection = conn;
                   cm.CommandText = storedProcName;
                   cm.CommandType = CommandType.StoredProcedure;
                   sum =(int)cm.ExecuteScalar();
                   conn.Close();
               }
               catch 
               {
                   if (MessageBox.Show("执行出错了!\n\r可能服务器不稳定!\n\r请关闭后重试!", "提示", MessageBoxButtons.YesNo) == DialogResult.Yes)
                   {
                       Application.Exit();
                   }
               }
               return sum;
           }
       }

  }
}
Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
C#调用mysql查询存储过程
废话不多说,最近做了一个mysql的查询的存储过程,现在主要给大家看的是dao部分和存储过程的生成和使用,其他部分不太重要。 首先先看表,主要有两张表,一张是订单表,一张是车票表,两者是一对多的关系,通过orderId关联。 再看的是存储过程的生成,新建一个查询,不然每次更改都打一遍很麻烦,其实主要目的是生成函数,生成的函数才是我们真正调用来执行的。该查询是生成一个输入参数为peopl
MySQL 存储过程查询远程数据库的方法
这几天有个任务,需要读取远程数据库一个表的数据存到本地表,然后进行计算。 在网上查找了资料,Oracle和SQL Server查询远程数据库是比较方便的,MySQL麻烦一些,需要在本地建立一个需要查询的远程的表结构完全一样的表,并且是Federate引擎。 1、首先,用show ENGINES语句查看是否安装Federate引擎。 如果有Federate记录但是Suppor
C#操作Mysql数据库的存储过程
近期在工作中接触了一套游戏服务端的代码,它是用C#写的逻辑,其中发现在客户端登陆的时候,服务端中处理登陆验证的模块没有先对账户名的合法性进行验证,而且还直接用sql语句拼接账户名的方法去查询数据库,很明显者存在一个SQL注入漏洞,为此我对写这代码的同胞鄙视了一番。鄙视归鄙视,作为一个5好青年,当然不会让这个洞存在下去。于是,我想了一会,觉得先要对接收到的账户名做合法性验证,然后sql语句要改成存储过
C#中执行mysql数据库的存储过程
C#中执行mysql数据库的存储过程
C# 调用mysql存储过程
这是一个web api框架下的项目,主要是为了给他人调用。 public IDictionary> GetDishes(string date, string windowid, int enjoyid) { IDictionary> v_order_menu = new Dictionary>(); String
mysql将查询结果写入变量,存储过程
我想把数据库里的表中的一个字段,8位数字,不够8位的前补0补足8位,大家有什么好办法呀,例 88 做成00000088 mysql把某个字段前补0怎么操作, 不用使用过程吧 select lpad(colname,8,'0') from tablename 这样应该可以 mysql 中有没有函数可以把整数转换为字符串 例如把 123 转换为 '123' select conver
SqlSugar实现数据的访问
“sqlsugar”组件实现数据访问 SqlSugar 是一款小巧,并且功能齐全的ORM,并不需要像Dapper一样依赖第三方扩展,语法易用简单 ,有漂亮的拉姆达语法,也支持Dapper SQL和ADO.NET(存储过程等)的所有功能,它的性能达到原生水准,远超 Dapper和EF CORE,而且支持.NET CORE , 多个数据库 1. 连接数据库 1)添加一个数据表...
C# 读取在存储过程多结果集
C# 读取在存储过程多结果集
C# 执行mysql 存储过程
#region 存储过程操作 /// /// 执行存储过程,返回SqlDataReader ( 注意:调用该方法后,一定要对SqlDataReader进行Close ) /// /// 存储过程名 /// 存储过程参数 /// SqlDataReader public static
从数据字典中查询存储过程, 函数, 包
--查询存储过程 --select * from user_source order by name; clear; select * from user_source where name = 'ADD_USER_INFORMATION'; --查询函数: --var sname = upper('get_sal'); --select * from user_source where name = 'GET_SAL'; select * from user_source where