postgresql-db-connection

Vocabulary

db.postgresql.private

Definition

USING: db ;

IN: db.postgresql.private

TUPLE: postgresql-db-connection < db-connection ;

Methods

USING: db.postgresql.private db.queries db.tuples db.types
kernel nmake sequences ;

M: postgresql-db-connection <insert-db-assigned-statement>
    [
        "select add_" 0% 0% "(" 0% dup find-primary-key first 2,
        remove-id [ ", " 0% ] [ bind% ] interleave ");" 0%
    ] query-make ;


USING: accessors db.postgresql db.postgresql.private db.queries
db.tuples db.types kernel nmake sequences ;

M: postgresql-db-connection <insert-user-assigned-statement>
    [
        "insert into " 0% 0% "(" 0% dup
        [ ", " 0% ] [ column-name>> 0% ] interleave ")" 0%
        " values(" 0%
        [ ", " 0% ] [
            dup type>> +random-id+ = [
                [ bind-name% slot-name>> f random-id-generator ]
                [ type>> ] bi <generator-bind> 1,
            ] [ bind% ] if
        ] interleave ");" 0%
    ] query-make ;


USING: db db.postgresql.private kernel ;

M: postgresql-db-connection <prepared-statement>
    <simple-statement> dup prepare-statement ;


USING: db db.postgresql db.postgresql.private ;

M: postgresql-db-connection <simple-statement>
    postgresql-statement new-statement ;


USING: accessors db.postgresql db.postgresql.private db.types
kernel nmake ;

M: postgresql-db-connection bind#
    [ bind-name% f swap type>> ] dip <literal-bind> 1, ;


USING: db.postgresql db.postgresql.private db.types nmake ;

M: postgresql-db-connection bind% bind-name% 1, ;


USING: combinators db.postgresql db.postgresql.private db.types
kernel math.parser sequences ;

M: postgresql-db-connection compound
    over {
        { "default" [ first number>string " " glue ] }
        {
            "varchar"
            [ first number>string "(" ")" surround append ]
        }
        { "references" [ >reference-string ] }
        [ drop no-compound-found ]
    } case ;


USING: db.postgresql db.postgresql.private db.tuples db.types
kernel make ;

M: postgresql-db-connection create-sql-statement
    [
        [ create-table-sql , ] keep dup db-assigned?
        [ create-function-sql , ] [ drop ] if
    ] { } make ;


USING: db db.postgresql.ffi db.postgresql.private ;

M: postgresql-db-connection db-close PQfinish ;


USING: db.postgresql db.postgresql.private db.tuples db.types
kernel make ;

M: postgresql-db-connection drop-sql-statement
    [
        [ drop-table-sql , ] keep dup db-assigned?
        [ drop-function-sql , ] [ drop ] if
    ] { } make ;


USING: db.postgresql.private db.tuples db.tuples.private ;

M: postgresql-db-connection insert-tuple-set-key
    query-modify-tuple ;


USING: accessors combinators db db.postgresql.errors
db.postgresql.private kernel sequences splitting ;

M: postgresql-db-connection parse-db-error
    split-lines dup length {
        { 1 [ first parse-postgresql-sql-error ] }
        { 2 [ concat parse-postgresql-sql-error ] }
        {
            3
            [
                first3 [ parse-postgresql-sql-error ] 2dip
                postgresql-location >>location
            ]
        }
    } case ;


USING: db.postgresql.private db.types random ;

M: postgresql-db-connection persistent-table
    H{
        { +unique+ { f f "unique" } }
        { system-random-generator { f f f } }
        { +null+ { f f "null" } }
        { +cascade+ { f f "cascade" } }
        { SIGNED-BIG-INTEGER { "bigint" "bigint" f } }
        { TIMESTAMP { "timestamp" "timestamp" f } }
        { +restrict+ { f f "restrict" } }
        { BIG-INTEGER { "bigint" "bigint" f } }
        { DATETIME { "timestamp" "timestamp" f } }
        { +user-assigned-id+ { f f f } }
        { TIME { "time" "time" f } }
        { VARCHAR { "varchar" "varchar" f } }
        { INTEGER { "integer" "integer" f } }
        { +on-delete+ { f f "on delete" } }
        { +db-assigned-id+ { "integer" "serial" f } }
        { BLOB { "bytea" "bytea" f } }
        { DOUBLE { "real" "real" f } }
        { URL { "varchar" "varchar" f } }
        { TEXT { "text" "text" f } }
        { +random-id+ { "bigint" "bigint" f } }
        { secure-random-generator { f f f } }
        { +not-null+ { f f "not null" } }
        { +set-null+ { f f "set null" } }
        { DATE { "date" "date" f } }
        { +on-update+ { f f "on update" } }
        { +autoincrement+ { f f "autoincrement" } }
        { random-generator { f f f } }
        { +foreign-id+ { f f "references" } }
        { +set-default+ { f f "set default" } }
        { UNSIGNED-BIG-INTEGER { "bigint" "bigint" f } }
        { +default+ { f f "default" } }
        { FACTOR-BLOB { "bytea" "bytea" f } }
    } ;