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

Question

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

sql:call userinfo(5);

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

有没有大神写个demo我学习一下，谢谢！

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

Answer 1

 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;
           }
       }

  }
}