Core/MysqlDBObject.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;  
using System.Configuration;
using System.Collections; 
using System.Collections.Generic; 
using System.Collections.Specialized; 
using System.Data; 
using System.Data.Common;
using System.Linq;
using System.Text.RegularExpressions;
using MySql.Data.MySqlClient; 
using DataObject.Dele;
using DataObject.Param;

namespace DataObject.Core
{
    /// <summary>
    /// Mysql数据访问层
    /// </summary>
    public class MysqlDBObject : DBBase
    {
        /// <summary>
        /// 构造函数
        /// </summary>
        /// <param name="constring">连接数据库字符串</param>
        public MysqlDBObject(string constring) {
            Connection = new MySqlConnection(constring);
        }

        /// <summary>
        /// 代理操作数据
        /// </summary>
        /// <param name="dataReader"></param>
        private delegate void Operate(MySqlDataReader dataReader);

        /// <summary>
        /// 数据库执行的脚本
        /// </summary>
        /// <param name="storedProcName">存储过程脚本</param>
        /// <param name="comType">执行类型</param>
        /// <param name="parameters">参数</param>
        /// <returns>执行命令</returns>
        private MySqlCommand BuildQueryCommand(string storedProcName, CommandType comType, params IDataParameter[] parameters) {
            MySqlCommand command = new MySqlCommand(storedProcName, Connection as MySqlConnection) { CommandType = comType, CommandTimeout = Timeout };
            if (parameters != null) {
                //重新封装参数
                List<MySqlParameter> mysqlParameter = new List<MySqlParameter>();
                foreach (IDataParameter par in parameters) {
                    mysqlParameter.Add(new MySqlParameter()
                    {
                        ParameterName=par.ParameterName,
                        Value = par.Value,
                        Direction = par.Direction,
                        DbType=par.DbType
                    });
                }
                command.Parameters.AddRange(mysqlParameter.ToArray());
            }
            return ReplaceSql(command);
        }