diff --git a/tests/e2e/staging_ingestion.test.js b/tests/e2e/staging_ingestion.test.js index 1aec07dd..66fe515e 100644 --- a/tests/e2e/staging_ingestion.test.js +++ b/tests/e2e/staging_ingestion.test.js @@ -1,9 +1,7 @@ const { expect } = require('chai'); const config = require('./utils/config'); -const logger = require('./utils/logger')(config.logger); const { DBSQLClient } = require('../..'); const fs = require('fs'); -const globalConfig = require('../../dist/globalConfig').default; describe('Staging Test', () => { it('put staging data and receive it', async () => { @@ -32,32 +30,6 @@ describe('Staging Test', () => { expect(result.toString() === 'Hello World!').to.be.true; }); - it('put staging data and receive it', async () => { - const client = new DBSQLClient(); - await client.connect({ - host: config.host, - path: config.path, - token: config.token, - }); - let tempPath = 'tests/e2e/staging/data'; - fs.writeFileSync(tempPath, (data = 'Hello World!')); - - let session = await client.openSession({ - initialCatalog: config.database[0], - initialSchema: config.database[1], - }); - await session.executeStatement( - `PUT '${tempPath}' INTO '/Volumes/${config.database[0]}/${config.database[1]}/e2etests/file1.csv' OVERWRITE`, - { stagingAllowedLocalPath: ['tests/e2e/staging'] }, - ); - await session.executeStatement( - `GET '/Volumes/${config.database[0]}/${config.database[1]}/e2etests/file1.csv' TO 'tests/e2e/staging/file'`, - { stagingAllowedLocalPath: ['tests/e2e/staging'] }, - ); - let result = fs.readFileSync('tests/e2e/staging/file'); - expect(result.toString() === 'Hello World!').to.be.true; - }); - it('put staging data and remove it', async () => { const client = new DBSQLClient(); await client.connect({