C#连接mysql 然后查询一个名为userinfo的存储过程,传参5
sql:call userinfo(5);
这个是查询用户的信息的存储过程,执行这个sql,然后获得查询出来的结果,并且输出。
有没有大神写个demo我学习一下,谢谢!
//正常执行sql语句我会,不会查存储过程
C#连接mysql 然后查询一个名为userinfo的存储过程,传参5
sql:call userinfo(5);
这个是查询用户的信息的存储过程,执行这个sql,然后获得查询出来的结果,并且输出。
有没有大神写个demo我学习一下,谢谢!
//正常执行sql语句我会,不会查存储过程
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;
}
}
}
}