File tree 2 files changed +21
-1
lines changed
2 files changed +21
-1
lines changed Original file line number Diff line number Diff line change @@ -664,7 +664,7 @@ var PgDriver = Base.extend({
664
664
var sql =
665
665
`SELECT ${ this . escapeDDL ( 'key' ) } ,
666
666
${ this . escapeDDL ( 'value' ) } ,
667
- ${ this . escapeDDL ( 'run_on' ) } ::STRING
667
+ ${ this . escapeDDL ( 'run_on' ) } ::${ this . mapDataType ( this . type . STRING ) }
668
668
FROM ` +
669
669
this . _escapeDDL +
670
670
table +
Original file line number Diff line number Diff line change @@ -38,6 +38,7 @@ lab.experiment('pg', () => {
38
38
meta = _meta ;
39
39
40
40
db = con ;
41
+ Promise . promisifyAll ( db ) ;
41
42
} ) ;
42
43
43
44
lab . experiment ( 'connections' , ( ) => {
@@ -968,6 +969,25 @@ lab.experiment('pg', () => {
968
969
} ) ;
969
970
} ) ;
970
971
972
+ lab . experiment ( '_getKV' , ( ) => {
973
+ let rows ;
974
+
975
+ lab . before ( async ( ) => {
976
+ await db . _createKV ( 'test' ) ;
977
+ } ) ;
978
+
979
+ lab . test ( 'can read written keys' , async ( ) => {
980
+ await db . _insertKV ( 'test' , 'test' , 'test123' ) ;
981
+ const e = await db . _getKV ( 'test' , 'test' ) ;
982
+ expect ( e ) . to . exist ( ) ;
983
+ expect ( e . value ) . to . equal ( 'test123' ) ;
984
+ } ) ;
985
+
986
+ lab . after ( async ( ) => {
987
+ await db . dropTable ( 'test' ) ;
988
+ } ) ;
989
+ } ) ;
990
+
971
991
lab . after ( ( ) => db . close ( ) ) ;
972
992
} ) ;
973
993
You can’t perform that action at this time.
0 commit comments