Npgsql: Validate marshalling OBJECT types as STRING, and query it

Author: amotl

by-language/csharp-npgsql/DemoTypes.cs

@@ -114,7 +114,7 @@ INSERT INTO testdrive.example (
                 timestamp_notz,
                 ip,
                 ""array"",
-                -- ""object"",
+                ""object"",
                 geopoint,
                 -- geoshape,
                 float_vector
@@ -133,7 +133,7 @@ INSERT INTO testdrive.example (
                 @timestamp_notz,
                 @ip,
                 @array,
-                -- @object,
+                @object,
                 @geopoint,
                 -- @egoshape,
                 @float_vector
@@ -157,6 +157,7 @@ INSERT INTO testdrive.example (
                 cmd.Parameters.AddWithValue("array", new List<string>{"foo", "bar"});
                 // FIXME: System.NotSupportedException: Cannot resolve 'hstore' to a fully qualified datatype name. The datatype was not found in the current database info.
                 // cmd.Parameters.AddWithValue("object", new Dictionary<string, string>(){{"foo", "bar"}});
+                cmd.Parameters.AddWithValue("object", @"{""foo"": ""bar""}");
                 cmd.Parameters.AddWithValue("geopoint", new List<double>{85.43, 66.23});
                 // FIXME: Npgsql.PostgresException : XX000: line 38:9: no viable alternative at input 'VALUES
                 // cmd.Parameters.AddWithValue("geoshape", "POLYGON ((5 5, 10 5, 10 10, 5 10, 5 5))");
@@ -183,6 +184,66 @@ INSERT INTO testdrive.example (
 
         }
 
+        public static async Task<DataTable> ContainerTypesExample(NpgsqlConnection conn)
+        {
+            Console.WriteLine("Running AllTypesExample");
+
+            // Submit DDL, create database schema.
+            await using (var cmd = new NpgsqlCommand("DROP TABLE IF EXISTS testdrive.container", conn))
+            {
+                cmd.ExecuteNonQuery();
+            }
+
+            await using (var cmd = new NpgsqlCommand(@"
+                CREATE TABLE testdrive.container (
+                    -- Container types
+                    ""array"" ARRAY(STRING),
+                    ""object"" OBJECT(DYNAMIC)
+                );
+            ", conn))
+            {
+                cmd.ExecuteNonQuery();
+            }
+
+            // Insert single data point.
+            await using (var cmd = new NpgsqlCommand(@"
+                INSERT INTO testdrive.container (
+                    ""array"",
+                    ""object""
+                ) VALUES (
+                    @array,
+                    @object
+                );
+        ", conn))
+            {
+                Console.WriteLine(cmd);
+                // FIXME: While doing conversations with ARRAY types works natively,
+                //        it doesn't work for OBJECT types.
+                //        Yet, they can be submitted as STRING in JSON format.
+                cmd.Parameters.AddWithValue("array", new List<string>{"foo", "bar"});
+                cmd.Parameters.AddWithValue("object", @"{""foo"": ""bar""}");
+                cmd.ExecuteNonQuery();
+            }
+
+            // Flush data.
+            await using (var cmd = new NpgsqlCommand("REFRESH TABLE testdrive.container", conn))
+            {
+                cmd.ExecuteNonQuery();
+            }
+
+            // Query back data.
+            await using (var cmd = new NpgsqlCommand("SELECT * FROM testdrive.container", conn))
+            await using (var reader = cmd.ExecuteReader())
+            {
+                var dataTable = new DataTable();
+                dataTable.Load(reader);
+                var payload = JsonConvert.SerializeObject(dataTable);
+                Console.WriteLine(payload);
+                return (DataTable) dataTable;
+            }
+
+        }
+
     }
 
 }

by-language/csharp-npgsql/tests/DemoProgramTest.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Collections.Generic;
+using System.Data;
 using System.Linq;
 using System.Threading.Tasks;
 using Npgsql;
@@ -111,8 +112,12 @@ public async Task TestAllTypesExample()
             Assert.Equal("127.0.0.1", row["ip"]);
 
             // Container types
+            // FIXME: While doing conversations with ARRAY types works natively,
+            //        it doesn't work for OBJECT types.
+            //        Yet, they can be submitted as STRING in JSON format.
             Assert.Equal(new List<string>{"foo", "bar"}, row["array"]);
-            Assert.Equal(DBNull.Value, row["object"]);  // FIXME
+            Assert.Equal(@"{""foo"":""bar""}", row["object"]);
+
             // Geospatial types
             // Assert.Equal(new List<double>{85.43, 66.23}, row["geopoint"]);  // TODO
             Assert.Equal("(85.42999997735023,66.22999997343868)", row["geopoint"].ToString());  // FIXME
@@ -122,5 +127,42 @@ public async Task TestAllTypesExample()
             Assert.Equal((new List<double>{1.1, 2.2, 3.3}).Select(d => (float) d).ToArray(), row["float_vector"]);
         }
 
+        [Fact]
+        public async Task TestContainerTypesExample()
+        {
+            var conn = fixture.Db;
+
+            // Invoke database workload.
+            var task = DatabaseWorkloadsMore.ContainerTypesExample(conn);
+            var dt = await task.WaitAsync(TimeSpan.FromSeconds(0.5));
+
+            // Check results.
+            var row = dt.Rows[0];
+            // FIXME: While doing conversations with ARRAY types works natively,
+            //        it doesn't work for OBJECT types.
+            //        Yet, they can be submitted as STRING in JSON format.
+            Assert.Equal(new List<string>{"foo", "bar"}, row["array"]);
+            Assert.Equal(@"{""foo"":""bar""}", row["object"]);
+
+            // Run a special query indexing into ARRAY types.
+            await using (var cmd = new NpgsqlCommand(@"SELECT ""array[2]"" AS foo FROM testdrive.container", conn))
+            await using (var reader = cmd.ExecuteReader())
+            {
+                var dataTable = new DataTable();
+                dataTable.Load(reader);
+                Assert.Equal("bar", dataTable.Rows[0]["foo"]);
+            }
+
+            // Run a special query indexing into OBJECT types.
+            await using (var cmd = new NpgsqlCommand(@"SELECT ""object['foo']"" AS foo FROM testdrive.container", conn))
+            await using (var reader = cmd.ExecuteReader())
+            {
+                var dataTable = new DataTable();
+                dataTable.Load(reader);
+                Assert.Equal("bar", dataTable.Rows[0]["foo"]);
+            }
+
+        }
+
     }
 }