feat(spanner): add spangres support

acceptance/data/fixtures.rb

@@ -0,0 +1,282 @@
+module Acceptance
+
+    module Fixtures
+        def stuffs_ddl_statement
+        if emulator_enabled?
+            <<-STUFFS
+            CREATE TABLE stuffs (
+                id INT64 NOT NULL,
+                int INT64,
+                float FLOAT64,
+                bool BOOL,
+                string STRING(MAX),
+                byte BYTES(MAX),
+                date DATE,
+                timestamp TIMESTAMP OPTIONS (allow_commit_timestamp=true),
+                ints ARRAY<INT64>,
+                floats ARRAY<FLOAT64>,
+                bools ARRAY<BOOL>,
+                strings ARRAY<STRING(MAX)>,
+                bytes ARRAY<BYTES(MAX)>,
+                dates ARRAY<DATE>,
+                timestamps ARRAY<TIMESTAMP>
+            ) PRIMARY KEY (id)
+            STUFFS
+        else
+            <<-STUFFS
+            CREATE TABLE stuffs (
+                id INT64 NOT NULL,
+                int INT64,
+                float FLOAT64,
+                bool BOOL,
+                string STRING(MAX),
+                byte BYTES(MAX),
+                date DATE,
+                timestamp TIMESTAMP OPTIONS (allow_commit_timestamp=true),
+                numeric NUMERIC,
+                json JSON,
+                ints ARRAY<INT64>,
+                floats ARRAY<FLOAT64>,
+                bools ARRAY<BOOL>,
+                strings ARRAY<STRING(MAX)>,
+                bytes ARRAY<BYTES(MAX)>,
+                dates ARRAY<DATE>,
+                timestamps ARRAY<TIMESTAMP>,
+                numerics ARRAY<NUMERIC>,
+                json_array ARRAY<JSON>
+            ) PRIMARY KEY (id)
+            STUFFS
+        end
+        end
+
+        def stuff_pg_ddl_statement
+            <<-STUFFS
+                CREATE TABLE stuffs (
+                    id bigint NOT NULL,
+                    "int" bigint,
+                    "float" double precision,
+                    "numeric" NUMERIC,
+                    bool boolean,
+                    string character varying,
+                    byte bytea,
+                    PRIMARY KEY(id)
+                );
+            STUFFS
+        end
+
+        def stuffs_index_statement
+        "CREATE INDEX IsStuffsIdPrime ON stuffs(bool, id)"
+        end
+
+        def commit_timestamp_test_ddl_statement
+        <<-TEST
+            CREATE TABLE commit_timestamp_test(committs TIMESTAMP OPTIONS (allow_commit_timestamp=true)) PRIMARY KEY (committs)
+        TEST
+        end
+
+        def accounts_ddl_statement
+        <<-ACCOUNTS
+            CREATE TABLE accounts (
+            account_id INT64 NOT NULL,
+            username STRING(32),
+            friends ARRAY<INT64>,
+            active BOOL NOT NULL,
+            reputation FLOAT64,
+            avatar BYTES(8192)
+            ) PRIMARY KEY (account_id)
+        ACCOUNTS
+        end
+
+        def accounts_pg_ddl_statement
+            <<-ACCOUNTS
+            CREATE TABLE accounts (
+                account_id INT NOT NULL,
+                username TEXT,
+                active BOOL NOT NULL,
+                reputation FLOAT,
+                avatar bytea,
+                PRIMARY KEY(account_id)
+            );
+            ACCOUNTS
+        end
+
+        def lists_ddl_statement
+            <<-LISTS
+                CREATE TABLE task_lists (
+                account_id INT64 NOT NULL,
+                task_list_id INT64 NOT NULL,
+                description STRING(1024) NOT NULL
+                ) PRIMARY KEY (account_id, task_list_id),
+                INTERLEAVE IN PARENT accounts ON DELETE CASCADE
+            LISTS
+        end
+
+        def lists_pg_ddl_statement
+            <<-LISTS
+            CREATE TABLE task_lists (
+                account_id INT NOT NULL,
+                task_list_id INT NOT NULL,
+                description TEXT NOT NULL,
+                PRIMARY KEY (account_id, task_list_id)
+            ) INTERLEAVE IN PARENT accounts ON DELETE CASCADE
+            LISTS
+        end
+
+        def items_ddl_statement
+            <<-ITEMS
+                CREATE TABLE task_items (
+                account_id INT64 NOT NULL,
+                task_list_id INT64 NOT NULL,
+                task_item_id INT64 NOT NULL,
+                description STRING(1024) NOT NULL,
+                active BOOL NOT NULL,
+                priority INT64 NOT NULL,
+                due_date DATE,
+                created_at TIMESTAMP,
+                updated_at TIMESTAMP
+                ) PRIMARY KEY (account_id, task_list_id, task_item_id),
+                INTERLEAVE IN PARENT task_lists ON DELETE CASCADE
+            ITEMS
+        end
+
+        def numeric_pk_ddl_statement
+            return
+
+            <<-BOXES
+                CREATE TABLE boxes (
+                id NUMERIC NOT NULL,
+                name STRING(256) NOT NULL,
+                ) PRIMARY KEY (id)
+            BOXES
+        end
+
+        def numeric_composite_pk_ddl_statement
+            return
+
+            <<-BOX_ITEMS
+                CREATE TABLE box_items (
+                id INT64 NOT NULL,
+                box_id NUMERIC NOT NULL,
+                name STRING(256) NOT NULL
+                ) PRIMARY KEY (id, box_id)
+            BOX_ITEMS
+        end
+
+        def schema_pg_ddl_statements
+            [
+            stuff_pg_ddl_statement,
+            accounts_pg_ddl_statement,
+            lists_pg_ddl_statement
+            ].compact
+        end
+
+        def schema_ddl_statements
+        [
+            stuffs_ddl_statement,
+            stuffs_index_statement,
+            accounts_ddl_statement,
+            lists_ddl_statement,
+            items_ddl_statement,
+            commit_timestamp_test_ddl_statement,
+            numeric_pk_ddl_statement,
+            numeric_composite_pk_ddl_statement
+        ].compact
+        end
+
+        def stuffs_table_types
+        { id: :INT64,
+            int: :INT64,
+            float: :FLOAT64,
+            bool: :BOOL,
+            string: :STRING,
+            byte: :BYTES,
+            date: :DATE,
+            timestamp: :TIMESTAMP,
+            json: :JSON,
+            ints: [:INT64],
+            floats: [:FLOAT64],
+            bools: [:BOOL],
+            strings: [:STRING],
+            bytes: [:BYTES],
+            dates: [:DATE],
+            timestamps: [:TIMESTAMP],
+            jsons: [:JSON]
+        }
+        end
+
+        def stuffs_random_row id = SecureRandom.int64
+        { id: id,
+            int: rand(0..1000),
+            float: rand(0.0..100.0),
+            bool: [true, false].sample,
+            string: SecureRandom.hex(16),
+            byte: File.open("acceptance/data/face.jpg", "rb"),
+            date: Date.today + rand(-100..100),
+            timestamp: Time.now + rand(-60*60*24.0..60*60*24.0),
+            json: { venue: "Yellow Lake", rating: 10 },
+            ints: rand(2..10).times.map { rand(0..1000) },
+            floats: rand(2..10).times.map { rand(0.0..100.0) },
+            bools: rand(2..10).times.map { [true, false].sample },
+            strings: rand(2..10).times.map { SecureRandom.hex(16) },
+            bytes: [File.open("acceptance/data/face.jpg", "rb"),
+                    File.open("acceptance/data/landmark.jpg", "rb"),
+                    File.open("acceptance/data/logo.jpg", "rb")],
+            dates: rand(2..10).times.map { Date.today + rand(-100..100) },
+            timestamps: rand(2..10).times.map { Time.now + rand(-60*60*24.0..60*60*24.0) },
+            json_array: [{ venue: "Green Lake", rating: 8 }, { venue: "Blue Lake", rating: 9 }]
+        }
+        end
+
+        def default_account_rows
+        [
+            {
+            account_id: 1,
+            username: "blowmage",
+            reputation: 63.5,
+            active: true,
+            avatar: File.open("acceptance/data/logo.jpg", "rb"),
+            friends: [2]
+            }, {
+            account_id: 2,
+            username: "quartzmo",
+            reputation: 87.9,
+            active: true,
+            avatar: StringIO.new("iVBORw0KGgoAAAANSUhEUgAAAEAAAABACAYAAACqaXHeAAAAAXNSR0IArs4c6QAAABxpRE9UAAAAAgAAAAAAAAAgAAAAKAAAACAAAAAgAAABxj2CfowAAAGSSURBVHgB7Jc9TsNAEIX3JDkCPUV6KlpKFHEGlD4nyA04ACUXQKTgCEipUnKGNEbP0otentayicZ24SlWs7tjO/N9u/5J2b2+NUtuZcnwYE8BuQPyGZAPwXwLLPk5kG+BJa9+fgfkh1B+CeancL4F8i2Q/wWm/S/w+XFoTseftn0dvhu0OXfhpM+AGvzcEiYVAFisPqE9zrETJhHAlXfg2lglMK9z0f3RBfB+ZyRUV3x+erzsEIjjOBqc1xtNAIrvguybV3A9lkVHxlEE6GrrPb/ZvAySwlUnfCmlPQ+R8JCExvGtcRQBLFwj4FGkznX1VYDKPG/f2/MjwCksXACgdNUxJjwK9xwl4JihOwTFR0kIF+CABEPRnvsvPFctMoYKqAFSAFaMwB4pp3Y+bodIYL9WmIAaIOHxo7W8wiHvAjTvhUeNwwSgeAeAABbqOewC5hBdwFD4+9+7puzXV9fS6/b1wwT4tsaYAhwOOQdUQch5vgZCeAhAv3ZM31yYAAUgvApQQQ6n5w6FB/RVe1jdJOAPAAD//1eMQwoAAAGQSURBVO1UMU4DQQy8X9AgWopIUINEkS4VlJQo4gvwAV7AD3gEH4iSgidESpWSXyyZExP5lr0c7K5PsXBhec/2+jzjuWtent9CLdtu1mG5+gjz+WNr7IsY7eH+tvO+xfuqk4vz7CH91edFaF5v9nb6dBKm13edvrL+0Lk5lMzJkQDeJSkkgHF6mR8CHwMHCQR/NAQQGD0BAlwK4FCefQiefq+A2Vn29tG7igLAfmwcnJu/nJy3BMQkMN9HEPr8AL3bfBv7Bp+7/SoExMDjZwKEJwmyhnnmQIQEBIlz2x0iKoAvJkAC6TsTIH6MqRrEWUMSZF2zAwqT4Eu/e6pzFAIkmNSZ4OFT+VYBIIF//UqbJwnF/4DU0GwOn8r/JQYCpPGufEfJuZiA37ycQw/5uFeqPq4pfR6FADmkBCXjfWdZj3NfXW58dAJyB9W65wRoMWulryvAyqa05nQFaDFrpa8rwMqmtOZ0BWgxa6WvK8DKprTmdAVoMWulryvAyqa05nQFaDFrpa8rwMqmtOb89wr4AtQ4aPoL6yVpAAAAAElFTkSuQmCC"),
+            friends: [1]
+            }, {
+            account_id: 3,
+            username: "-inactive-",
+            active: false
+            }
+        ]
+        end
+
+        def default_pg_account_rows
+            [
+                {
+                account_id: 1,
+                username: "blowmage",
+                reputation: 63.5,
+                active: true,
+                avatar: File.open("acceptance/data/logo.jpg", "rb"),
+                }, {
+                account_id: 2,
+                username: "quartzmo",
+                reputation: 87.9,
+                active: true,
+                avatar: StringIO.new("iVBORw0KGgoAAAANSUhEUgAAAEAAAABACAYAAACqaXHeAAAAAXNSR0IArs4c6QAAABxpRE9UAAAAAgAAAAAAAAAgAAAAKAAAACAAAAAgAAABxj2CfowAAAGSSURBVHgB7Jc9TsNAEIX3JDkCPUV6KlpKFHEGlD4nyA04ACUXQKTgCEipUnKGNEbP0otentayicZ24SlWs7tjO/N9u/5J2b2+NUtuZcnwYE8BuQPyGZAPwXwLLPk5kG+BJa9+fgfkh1B+CeancL4F8i2Q/wWm/S/w+XFoTseftn0dvhu0OXfhpM+AGvzcEiYVAFisPqE9zrETJhHAlXfg2lglMK9z0f3RBfB+ZyRUV3x+erzsEIjjOBqc1xtNAIrvguybV3A9lkVHxlEE6GrrPb/ZvAySwlUnfCmlPQ+R8JCExvGtcRQBLFwj4FGkznX1VYDKPG/f2/MjwCksXACgdNUxJjwK9xwl4JihOwTFR0kIF+CABEPRnvsvPFctMoYKqAFSAFaMwB4pp3Y+bodIYL9WmIAaIOHxo7W8wiHvAjTvhUeNwwSgeAeAABbqOewC5hBdwFD4+9+7puzXV9fS6/b1wwT4tsaYAhwOOQdUQch5vgZCeAhAv3ZM31yYAAUgvApQQQ6n5w6FB/RVe1jdJOAPAAD//1eMQwoAAAGQSURBVO1UMU4DQQy8X9AgWopIUINEkS4VlJQo4gvwAV7AD3gEH4iSgidESpWSXyyZExP5lr0c7K5PsXBhec/2+jzjuWtent9CLdtu1mG5+gjz+WNr7IsY7eH+tvO+xfuqk4vz7CH91edFaF5v9nb6dBKm13edvrL+0Lk5lMzJkQDeJSkkgHF6mR8CHwMHCQR/NAQQGD0BAlwK4FCefQiefq+A2Vn29tG7igLAfmwcnJu/nJy3BMQkMN9HEPr8AL3bfBv7Bp+7/SoExMDjZwKEJwmyhnnmQIQEBIlz2x0iKoAvJkAC6TsTIH6MqRrEWUMSZF2zAwqT4Eu/e6pzFAIkmNSZ4OFT+VYBIIF//UqbJwnF/4DU0GwOn8r/JQYCpPGufEfJuZiA37ycQw/5uFeqPq4pfR6FADmkBCXjfWdZj3NfXW58dAJyB9W65wRoMWulryvAyqa05nQFaDFrpa8rwMqmtOZ0BWgxa6WvK8DKprTmdAVoMWulryvAyqa05nQFaDFrpa8rwMqmtOb89wr4AtQ4aPoL6yVpAAAAAElFTkSuQmCC"),
+                }, {
+                account_id: 3,
+                username: "-inactive-",
+                active: false
+                }
+            ]
+            end
+
+        def default_list_rows
+        end
+
+        def default_item_rows
+        end
+    end
+end