0

我正在使用 npgsql 检查 Postgresql Prepared Statements。它在安装 Postgresql 服务器的同一台机器上运行完美。在服务器（同一台机器）上使用简单的 100000 INSERT 随机值语句

它在大约 12.16 秒内插入 10 万条记录。8224 条记录/秒，如果未准备好。它在大约 7.76 秒内插入 10 万条记录。12886 条记录 / 秒如果 Prepared statement 与 127.0.0.1/172.16.16.33 相同的机器 在客户端（同一 LAN 中的另一台机器具有相同的 IP 范围和相同的配置 8Gb RAM）

它在大约 89.36 秒内插入 10 万条记录。1119 条记录/秒，如果未准备好。它在大约 87.95 秒内插入 10 万条记录。1137 条记录/秒。if 准备好的语句。 来自另一台 ip 为 172.16.16.35 的机器 LAN 上的这种性能是非常不可接受的。请帮忙。

我已经使用https://www.pgconfig.org/#/tuning配置了我的 postgresql 服务器

还禁用了两台计算机上的防病毒+防火墙。

该表已经 UNLOGGED 并且没有任何约束或索引。

Postgresql 版本 9.6.12


        private void button1_Click(object sender, EventArgs e)
        {
            button1.Enabled=false; 
            button2.Enabled=false;
            button3.Enabled = false;
            lblUnprepared.Text = "Executing... Please Wait...!";
            lblUnprepared.Refresh();
            npgCmd.CommandText = "TRUNCATE TABLE TBL_ETCBLACKLIST_TEST";
            npgCmd.ExecuteNonQuery();
            procInsertData();
        }

        private void procInsertData()
        {
            string strFileDownloadId = string.Empty;
            string strValues_0 = string.Empty;
            string strValues_1 = string.Empty;
            string strValues_2 = string.Empty;
            string strValues_3 = string.Empty;
            string strBlacklistFileNameWithoutExtension = string.Empty;

            DateTime strDateTime = DateTime.Now;

            DateTime strstarttime= DateTime.Now;


            objLog.Log(0, "Start Executing SQL");
            npgCmd.CommandType = CommandType.Text;
            npgCmd.Connection = npgConn;


            for (int i = 0; i <= lRows; i++)
            {
                //npgCmd = new NpgsqlCommand();
                //NpgsqlDataReader npgRD = null;

                strFileDownloadId = i.ToString();
                strValues_0 = RandomString(10, true) +  i;
                strValues_1 = RandomString(1, true);
                strValues_2 = DateTime.Now.ToString("yyyy/MM/dd hh:mm:ss");
                strValues_3 = RandomString(10, true);
                strBlacklistFileNameWithoutExtension = RandomString(10, true);

                strSQL = "INSERT INTO TBL_ETCBLACKLIST_TEST(ETCFileDownload_ID, ETC_Tag_ID, Tag_Status, Effective_Date, "
                   + " Reason_Code, CCHFile_ID, Create_DateTime, Last_Update_Date, CCHBank_ID) VALUES("
                   + strFileDownloadId + ", '" + strValues_0 + "', '" + strValues_1 + "', TO_TIMESTAMP('" + strValues_2 + "','YYYY/MM/DD HH24:MI:SS') "
                   + ", '" + strValues_3 + "', '" + strBlacklistFileNameWithoutExtension + "','" + DateTime.Now +"','" + DateTime.Now + "', 1 )";

                npgCmd.CommandText = strSQL;
              npgCmd.ExecuteNonQuery();
            }
            DateTime strEndTime = DateTime.Now;
            var diffInSeconds = (strEndTime - strstarttime).TotalSeconds;
            var lRecPerSec = Math.Round(lRows / diffInSeconds);
            lblUnprepared.Text = string.Format("UnPrepared SQL Inserted {0} Records In {1} Seconds \n@{2} Records Per Second.", lRows, diffInSeconds, lRecPerSec);

            objLog.Log(0, "UnPrepeared SQL Processed in: " + diffInSeconds); 
            //npgCmd.Dispose();
            //MessageBox.Show(string.Format("UnPreapared Statement Processed in {0} Seconds.", diffInSeconds));
            button1.Enabled = true;
            button2.Enabled = true;
            button3.Enabled = true;

            //npgRD.Dispose();
        }

        private void button2_Click(object sender, EventArgs e)
        {
            string strFileDownloadId = string.Empty;
            string strValues_0 = string.Empty;
            string strValues_1 = string.Empty;
            string strValues_2 = string.Empty;
            string strValues_3 = string.Empty;
            string strBlacklistFileNameWithoutExtension = string.Empty;

            DateTime strDateTime = DateTime.Now;
            DateTime strstarttime = DateTime.Now;

            button1.Enabled = false;
            button2.Enabled = false;
            button3.Enabled = false;

    npgCmd.CommandText = "TRUNCATE TABLE TBL_ETCBLACKLIST_TEST";
            npgCmd.ExecuteNonQuery();

            objLog.Log(0, "Start Executing SQL");
            lblPrepared.Text = "Executing... Please Wait...!";
            lblPrepared.Refresh();

            strSQL = "INSERT INTO TBL_ETCBLACKLIST_TEST(ETCFileDownload_ID, ETC_Tag_ID, Tag_Status, Effective_Date, "
               + " Reason_Code, CCHFile_ID, Create_DateTime, Last_Update_Date, CCHBank_ID) VALUES("
               + "@Param1 , @Param2,@Param3,@Param4,@Param5,@Param6,@Param7,@Param8,@Param9)";

            npgCmd.CommandText = strSQL;
            npgCmd.CommandType = CommandType.Text;
            npgCmd.Connection = npgConn;

            npgCmd.Parameters.Add("@Param1", NpgsqlDbType.Numeric);

            npgCmd.Parameters.Add("@Param2", NpgsqlDbType.Text);
            npgCmd.Parameters.Add("@Param3", NpgsqlDbType.Text);
            npgCmd.Parameters.Add("@Param4", NpgsqlDbType.Date);
            npgCmd.Parameters.Add("@Param5", NpgsqlDbType.Text);
            npgCmd.Parameters.Add("@Param6", NpgsqlDbType.Text);
            npgCmd.Parameters.Add("@Param7", NpgsqlDbType.Date);
            npgCmd.Parameters.Add("@Param8", NpgsqlDbType.Date);
            npgCmd.Parameters.Add("@Param9", NpgsqlDbType.Numeric);
            npgCmd.Prepare();

            for (int i = 0; i <= lRows; i++)
            {
//                npgCmd = new NpgsqlCommand();

                strFileDownloadId = i.ToString();
                strValues_0 = RandomString(10, true) + i;
                strValues_1 = RandomString(1, true);
                strValues_2 = DateTime.Now.ToString("yyyy/MM/dd hh:mm:ss");
                strValues_3 = RandomString(10, true);
                strBlacklistFileNameWithoutExtension = RandomString(10, true);
                npgCmd.Parameters[0].Value = strFileDownloadId;
                npgCmd.Parameters[1].Value = strValues_0;
                npgCmd.Parameters[2].Value = strValues_1;
                npgCmd.Parameters[3].Value = strValues_2;
                npgCmd.Parameters[4].Value = strValues_3;
                npgCmd.Parameters[5].Value = strBlacklistFileNameWithoutExtension;
                npgCmd.Parameters[6].Value = DateTime.Now;
                npgCmd.Parameters[7].Value = DateTime.Now;
                npgCmd.Parameters[8].Value = 1;

                npgCmd.ExecuteNonQuery();
            }
            DateTime strEndTime = DateTime.Now;

            var diffInSeconds = (strEndTime - strstarttime).TotalSeconds;
            var lRecPerSec = Math.Round(lRows / diffInSeconds);

            lblPrepared.Text = string.Format("Prepared SQL Inserted {0} Records In {1} Seconds \n@ {2} Records Per Second.", lRows, diffInSeconds, lRecPerSec);
            //MessageBox.Show(string.Format("Preapared SQL Processed in {0} Seconds.", diffInSeconds));
            objLog.Log(0, "Prepeared SQL Processed in: " + diffInSeconds);

            lblPrepared.Text = string.Format("Prepared SQL Inserted {0} Records In {1} Seconds \n@ {2} Records Per Second.", lRows, diffInSeconds, lRecPerSec);
            //MessageBox.Show(string.Format("Preapared SQL Processed in {0} Seconds.", diffInSeconds));
            objLog.Log(0, "Prepeared SQL Processed in: " + diffInSeconds);

            button1.Enabled = true;
            button2.Enabled = true;
            button3.Enabled = true;

            //Cant find npgsql.Unprepare();
            //npgCmd.Dispose();
            //npgRD.Dispose();
        }

postgresql.auto.conf 如下。

shared_buffers = '512MB'
effective_cache_size = '6GB'
work_mem = '82MB'
maintenance_work_mem = '512MB'
min_wal_size = '512MB'
max_wal_size = '2GB'
checkpoint_completion_target = '0.7'
wal_buffers = '16MB'
listen_addresses = '*'
max_connections = '100'
random_page_cost = '4.0'
logging_collector = 'on'
log_checkpoints = 'on'
log_connections = 'on'
log_disconnections = 'on'
log_lock_waits = 'on'
log_temp_files = '0'
lc_messages = 'C'
log_min_duration_statement = '10s'
log_autovacuum_min_duration = '0'
log_destination = 'stderr'
log_line_prefix = '%t [%p]: [%l-1] user=%u,db=%d,app=%a,client=%h '
4

2 回答 2

2

正如@felice-pollano 上面所写，您可能想查看Npgsql 的批量复制支持，它允许您在单次往返中插入大量数据。它往往比简单的插入要优化得多。

如果您对每个 SQL 执行一次往返，那么与 localhost 相比，LAN 上的性能大幅下降是有意义的。在后者中几乎没有延迟，但在前者中，您大部分时间都在等待协议消息到达 PostgreSQL 并返回。

于 2019-05-06T15:15:27.913 回答
1

如果它在 LAN 上变慢可能是由于 LAN 问题。顺便说一句，大规模插入通常需要使用某种“批量”或“批处理”策略来完成，每次与数据库交谈可能比实际执行数据库代码花费更多的时间。

于 2019-05-06T10:11:15.757 回答