修改Postgres数据库帮助类

13693261870

2023-08-21 8482a6fef58c0d699795435ef525a8f188e502a1

 DataLoader/CS/PostgreHelper.cs

@@ -5,9 +5,8 @@
using System.Data;
using System.Data.Common;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using System.Web;

namespace DataLoader.CS
{
@@ -29,11 +28,9 @@

        private string conStr = null;

        public PostgreHelper(DbEnum db)
        public PostgreHelper()
        {
            string str = ConfigurationManager.AppSettings["pgConn"];

            this.conStr = string.Format(str, db.ToString());
            this.conStr = ConfigurationManager.AppSettings["pgConn"];
        }

        /// <summary>
@@ -135,6 +132,32 @@
            }
        }

        public int GetIntScalar(string sql, params DbParameter[] args)
        {
            using (NpgsqlConnection con = new NpgsqlConnection(ConStr))
            {
                if (con.State != ConnectionState.Open)
                {
                    con.Open();
                }

                using (NpgsqlCommand cmd = new NpgsqlCommand(sql, con))
                {
                    if (args != null)
                    {
                        foreach (DbParameter arg in args)
                        {
                            cmd.Parameters.Add(arg);
                        }
                    }

                    object obj = cmd.ExecuteScalar();

                    return null == obj ? 0 : Convert.ToInt32(obj);
                }
            }
        }

        /// <summary>
        /// 执行SQL，返回影响行数
        /// </summary>