Re: Postgres refusing to use >1 core
От | Merlin Moncure |
---|---|
Тема | Re: Postgres refusing to use >1 core |
Дата | |
Msg-id | BANLkTinAys0Z3fDj4UQitTbuH+CKPCs=WA@mail.gmail.com обсуждение исходный текст |
Ответ на | Re: Postgres refusing to use >1 core (Aren Cambre <aren@arencambre.com>) |
Список | pgsql-performance |
On Mon, May 9, 2011 at 9:40 PM, Aren Cambre <aren@arencambre.com> wrote: >> how are you reading through the table? if you are using OFFSET, you >> owe me a steak dinner. >> > > Nope. :-) > Below is my exact code for the main thread. The C# PLINQ statement is > highlighted. Let me know if I can help to explain this. > > NpgsqlConnection arrestsConnection = new > NpgsqlConnection(Properties.Settings.Default.dbConnectionString); > > arrestsConnection.Open(); > > > > /// First clear out the geocoding table > > NpgsqlCommand geocodingTableClear = new NpgsqlCommand("TRUNCATE > raw.\"TxDPS geocoding\"", arrestsConnection); > > geocodingTableClear.ExecuteNonQuery(); > > > > NpgsqlDataReader arrests = new NpgsqlCommand("SELECT * FROM > \"raw\".\"TxDPS all arrests\"", arrestsConnection).ExecuteReader(); > > > > /// Based on the pattern defined at > > /// > http://social.msdn.microsoft.com/Forums/en-US/parallelextensions/thread/2f5ce226-c500-4899-a923-99285ace42ae. > > foreach(IDataRecord arrest in > > from row in arrests.AsParallel().Cast <IDataRecord>() > > select row) > > { > > Geocoder geocodeThis = new Geocoder(arrest); > > geocodeThis.Geocode(); > > } > > > > arrestsConnection.Close(); hm. I'm not exactly sure. how about turning on statement level logging on the server for a bit and seeing if any unexpected queries are being generated and sent to the server. merlin
В списке pgsql-performance по дате отправления: