@@ -103,6 +103,27 @@ describe('SDK configuration tests', () => {
103103 } ) ;
104104} ) ;
105105
106+ test ( 'Destroy functionality' , async ( ) => {
107+ const knex = require ( 'knex' ) ( {
108+ client : require ( '..' ) ,
109+ connection : {
110+ database : constants . DATABASE ,
111+ resourceArn : constants . AURORA_CLUSTER_ARN ,
112+ secretArn : constants . SECRET_ARN
113+ }
114+ } ) ;
115+
116+ mockExecuteStatementPromise . mockResolvedValue ( constants . ALL_QUERY_RESPONSE_DATA ) ;
117+
118+ await knex . select ( '*' ) . from ( 'foo' ) ;
119+
120+ expect ( mockExecuteStatement ) . toHaveBeenCalledTimes ( 1 ) ;
121+
122+ knex . destroy ( ) ;
123+
124+ await expect ( knex . select ( '*' ) . from ( 'foo' ) ) . rejects . toThrow ( ) ;
125+ } ) ;
126+
106127describe ( 'Query statement tests' , ( ) => {
107128 const knex = require ( 'knex' ) ( {
108129 client : require ( '..' ) ,
@@ -300,6 +321,24 @@ describe('Query statement tests', () => {
300321 expect ( rows ) . toEqual ( constants . PLUCK_RESPONSE_ROWS ) ;
301322 } ) ;
302323
324+ test ( '.del() works' , async ( ) => {
325+ mockExecuteStatementPromise . mockResolvedValue ( constants . DEL_RESPONSE_DATA ) ;
326+
327+ const rows = await knex ( 'test' ) . del ( ) ;
328+
329+ expect ( mockExecuteStatement ) . toHaveBeenCalledTimes ( 1 ) ;
330+ expect ( mockExecuteStatement ) . toHaveBeenCalledWith ( {
331+ resourceArn : constants . AURORA_CLUSTER_ARN ,
332+ secretArn : constants . SECRET_ARN ,
333+ database : constants . DATABASE ,
334+ sql : 'delete from `test`' ,
335+ parameters : [ ] ,
336+ includeResultMetadata : true
337+ } ) ;
338+
339+ expect ( rows ) . toEqual ( constants . DEL_RESPONSE_ROWS ) ;
340+ } ) ;
341+
303342 test ( "Insert returns first row's primary ID" , async ( ) => {
304343 mockExecuteStatementPromise . mockResolvedValue ( constants . INSERT_RESPONSE_DATA ) ;
305344
0 commit comments