fixtures.rb

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