thunderstrike/purescript-postgresql-client
thunderstrike/purescript-postgresql-client
2
0
Fork 0
generated from tpl/purs
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add string array OID and check for OIDs

Browse Source
This commit is contained in:
rightfold 2016-12-22 23:22:00 +01:00
parent d86e229702
commit 6fb1844d4d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
purspgpp
View File

@ -60,6 +60,7 @@ my Str:D %types{Int:D} =
25 => 'String', 25 => 'String',
701 => 'Number', 701 => 'Number',
2950 => 'UUID', 2950 => 'UUID',
2951 => 'List String',
; ;
sub process-module(libpq::Connection:D $conn, Str:D $segment --> Str:D) { sub process-module(libpq::Connection:D $conn, Str:D $segment --> Str:D) {
@ -69,7 +70,10 @@ sub process-module(libpq::Connection:D $conn, Str:D $segment --> Str:D) {
sub process-query(libpq::Connection:D $conn, Str:D $source --> Str:D) { sub process-query(libpq::Connection:D $conn, Str:D $source --> Str:D) {
$conn.prepare('', $source); $conn.prepare('', $source);
my $description = $conn.describe-prepared(''); my $description = $conn.describe-prepared('');
my &convert-types = { ($_.map({%types{$_}}), "Unit").flat.join(" × "); }; my &convert-types = {
die "unknown oid: $_" unless %types{$_}:exists for $_;
($_.map({%types{$_}}), "Unit").flat.join(" × ");
};
my $parameters = &convert-types($description.parameters); my $parameters = &convert-types($description.parameters);
my $fields = &convert-types($description.fields); my $fields = &convert-types($description.fields);
"(Query \"\"\"$source\"\"\" :: Query ($parameters) ($fields))"; "(Query \"\"\"$source\"\"\" :: Query ($parameters) ($fields))";