Re: Postgres refusing to use >1 core

[Aren Cambre <aren@xxxxxxxxxxxxxx>]

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();

 

Aren