u010384336 2016-04-07 10:51 采纳率: 90.9%
浏览 1738

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

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

sql:call userinfo(5);

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

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

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

  • 写回答

1条回答 默认 最新

  • threenewbee 2016-04-07 20: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;
               }
           }
    
      }
    }
    
    评论

报告相同问题?

悬赏问题

  • ¥15 机器学习教材中的例题询问
  • ¥15 求.net core 几款免费的pdf编辑器
  • ¥15 C# P/Invoke的效率问题
  • ¥20 thinkphp适配人大金仓问题
  • ¥20 Oracle替换.dbf文件后无法连接,如何解决?(相关搜索:数据库|死循环)
  • ¥15 数据库数据成问号了,前台查询正常,数据库查询是?号
  • ¥15 算法使用了tf-idf,用手肘图确定k值确定不了,第四轮廓系数又太小才有0.006088746097507285,如何解决?(相关搜索:数据处理)
  • ¥15 彩灯控制电路,会的加我QQ1482956179
  • ¥200 相机拍直接转存到电脑上 立拍立穿无线局域网传
  • ¥15 (关键词-电路设计)