【笔记】.NET开发环境下使用PostgreSQL+Oracle_fdw 实现两个数据库之间数据交互操作（二）

一 新的可视化工具

    因为前文所提到的，看不到外部服务器和外部表的问题，我更换了可视化工具。

    好用的新工具PostgreSQL Maestro！  

    当然如此好用的工具不是免费的，如果想免费使用还请自己去找，本文不提供此类下载。

    1.1 这里发现的问题是，postgreSql查询的字段如果是大写，那必须要加双引号，不然无法查询到该字段，例如：

    表a字段名为大写的ID，NAME，TYPE，REMARK，

    查询

select ID,NAME,TYPE,REMARK from a

   是会说没有ID这个字段的，

   要改为

select "ID","NAME","TYPE","REMARK" from a

    才可以正常执行。所以建议外部表可以把字段名改为全小写。但在使用全小写字段时，语句字段使用大写不加双引号却是可以执行的！运行创建表字段的脚本时，字段大写但不加双引号，添加的字段名会是全小写！还真挺绕的。

    1.2还有一个问题是，在执行为字段添加注释的脚本时，由于是中文，在PostgreSQL Maestro工具中某些中文会引起报错。

    而在pgAdmin中执行就没有问题，也是有点神奇的现象。初步推测是PostgreSQL Maestro编码的问题，有待以后研究考证。

二 在.NET项目中访问postgreSql数据库

  2.1 第三方类库

    Npgsql提供 .NET 操作postgreSQL数据库的相关类。支持postgreSQL7.x 及以上版本。

  2.2 PostgreSQLHelper类

    综合了网上其大佬的一些写法，再模仿oracle已经写好的helper文件，自己简单写了一些常用的访问数据库方法。如下：

 public static string connectionString = PubConstant.PgConnectionString;//获得配置文件中的链接字符串
        public MyDbHelperPgsql()
        {            
        } 

        /// <summary>
        /// 执行SQL语句，返回查询的唯一值记录
        /// </summary>
        /// <param name="SQLString">SQL语句</param>
        /// <returns>查询的唯一值记录</returns>
        public static int ExecuteSql(string SQLString)
        {
            using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))
            {
                try
                {
                    conn.Open();
                    NpgsqlCommand objCommand = new NpgsqlCommand(SQLString, conn);
                    int count = Convert.ToInt32(objCommand.ExecuteScalar());
                    return count;
                }
                finally
                {
                    conn.Close();
                }
            }
        }

        /// <summary>
        /// 执行SQL语句,返回影响的记录数
        /// </summary>
        /// <param name="SQLString">SQL语句</param>
        /// <returns>返回影响的记录数</returns>
        public static int ExecuteNonQuery(string SQLString)
        {

            NpgsqlCommand cmd = new NpgsqlCommand();

            using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))
            {
                PrepareCommand(cmd, conn, null, SQLString, null);
                int val = cmd.ExecuteNonQuery();
                cmd.Parameters.Clear();
                return val;
            }  
        }

        /// <summary>  
        /// 在事务中执行 Transact-SQL 语句并返回受影响的行数。  
        /// </summary>  
        public static int ExecuteNonQuery(string cmdText,params DbParameter[] cmdParms)
        {
            
            using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))
            {
                try
                {
                    conn.Open();
                    NpgsqlCommand cmd = new NpgsqlCommand();
                    cmd.Connection = conn;
                    NpgsqlTransaction tx = conn.BeginTransaction();
                    cmd.Transaction = tx;
                    PrepareCommand(cmd, tx.Connection, tx, cmdText, cmdParms);
                    int val = cmd.ExecuteNonQuery();
                    cmd.Parameters.Clear();
                    return val;
                }
                finally
                {
                    conn.Close();
                }
            }
        }  

        /// <summary>
        /// 执行查询语句，返回DataSet
        /// </summary>
        /// <param name="SQLString">查询语句</param>
        /// <returns>DataSet</returns>
        public static DataSet Query(string SQLString)
        {
            using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))
            {
                DataSet ds = new DataSet();
                try
                {
                    conn.Open();
                    using (NpgsqlCommand command = new NpgsqlCommand(SQLString, conn))
                    {
                        using (NpgsqlDataAdapter da = new NpgsqlDataAdapter(command))
                        {
                            da.Fill(ds, "ds");
                            return ds;
                        }
                    }
                }
                finally
                {

                    conn.Close();
                }
                
            }
        }

        /// <summary>
        /// 执行查询语句，返回DataSet
        /// </summary>
        /// <param name="cmdText">查询语句</param>
        /// <param name="cmdParms">参数</param>
        /// <returns>DataSet</returns>
        public static DataSet ExecuteQuery(string cmdText, params DbParameter[] cmdParms)
        {
            using (NpgsqlConnection conn = new NpgsqlConnection(connectionString))
            {
                using (NpgsqlCommand cmd = new NpgsqlCommand())
                {
                    PrepareCommand(cmd, conn, null, cmdText, cmdParms);
                    using (NpgsqlDataAdapter da = new NpgsqlDataAdapter(cmd))
                    {
                        DataSet ds = new DataSet();
                        da.Fill(ds, "ds");
                        cmd.Parameters.Clear();
                        return ds;
                    }
                }
            }
        }



        /// <summary>  
        /// 生成要执行的命令  
        /// </summary>  
        /// <remarks>参数的格式：冒号+参数名</remarks>  
        private static void PrepareCommand(DbCommand cmd, DbConnection conn, DbTransaction trans, string cmdText, DbParameter[] cmdParms)
        {
            if (conn.State != ConnectionState.Open)
                conn.Open();

            cmd.Connection = conn;
            cmd.CommandText = cmdText.Replace("@", ":").Replace("?", ":").Replace("[", """).Replace("]", """);

            if (trans != null)
                cmd.Transaction = trans;

            cmd.CommandType = CommandType.Text;

            if (cmdParms != null)
            {
                foreach (NpgsqlParameter parm in cmdParms)
                {
                    parm.ParameterName = parm.ParameterName.Replace("@", ":").Replace("?", ":");

                    cmd.Parameters.Add(parm);
                }
            }
        }  

    Web.config中设置sql链接

<add key="PgConnectionString" value="Server=192.xxx.xxx.xxx;Port=5432;User Id=用户名;Password=密码;Database=数据库名;"/>

    其中事务的用法还没有研究明白，NpgsqlTransaction 还没有弄懂要怎么使用。以后将补充。

   

 三 远程连接postgreSql数据库

  之前提到的，整个系统调通后，要把数据库迁移到服务器上。这时本机访问远程数据库就要在服务器上进行一系列配置了。

PostgreSQLHelper类
作者： JerryAndTom
链接：https://www.imooc.com/article/12444
来源：慕课网

PostgreSQLHelper类
作者： JerryAndTom
链接：https://www.imooc.com/article/12444
来源：慕课网

  在PostgreSQLdata 找到配置文件pg_hba.conf，修改如下：

 

# IPv4 local connections:
host    all             all             127.0.0.1/32            md5
host    all             all             192.xxx.xxx.1/24          md5
# IPv6 local connections:
#host    all             all             ::1/128                 md5
# Allow replication connections from localhost, by a user with the
# replication privilege.
#host    replication     postgres        127.0.0.1/32            md5
#host    replication     postgres        ::1/128                 md5

  添加红色部分，xxx是自己所需要允许访问的ip段。

PostgreSQLHelper类
作者： JerryAndTom
链接：https://www.imooc.com/article/12444
来源：慕课网

PostgreSQLHelper类
作者： JerryAndTom
链接：https://www.imooc.com/article/12444
来源：慕课网