【笔记】.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
来源：慕课网

在\PostgreSQL\data 找到配置文件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
来源：慕课网