Method Run

compatibility/pg/csharp/PGTest.cs:100–152

(NpgsqlCommand cmd)

            }

            public bool Run(NpgsqlCommand cmd)
            {
                try
                {
                    Console.WriteLine("Running test: " + query);
                    cmd.CommandText = query;
                    using (var reader = cmd.ExecuteReader())
                    {
                        if (!reader.HasRows)
                        {
                            if (expectedResults.Length != 0)
                            {
                                Console.Error.WriteLine($"Expected {expectedResults.Length} rows, got 0");
                                return false;
                            }
                            Console.WriteLine("Returns 0 rows");
                            return true;
                        }
                        if (reader.FieldCount != expectedResults[0].Length)
                        {
                            Console.Error.WriteLine($"Expected {expectedResults[0].Length} columns, got {reader.FieldCount}");
                            return false;
                        }
                        int rows = 0;
                        while (reader.Read())
                        {
                            for (int col = 0; col < expectedResults[rows].Length; col++)
                            {
                                string result = reader.GetValue(col).ToString().Trim();
                                if (expectedResults[rows][col] != result)
                                {
                                    Console.Error.WriteLine($"Expected:\n'{expectedResults[rows][col]}'");
                                    Console.Error.WriteLine($"Result:\n'{result}'");
                                    return false;
                                }
                            }
                            rows++;
                        }
                        Console.WriteLine("Returns " + rows + " rows");
                        if (rows != expectedResults.Length)
                        {
                            Console.Error.WriteLine($"Expected {expectedResults.Length} rows");
                            return false;
                        }
                        return true;
                    }
                }
                catch (NpgsqlException e)
                {
                    Console.Error.WriteLine(e.Message);
                    return false;
                }
            }
        }
    }