mssql-destination.spec.ts

import { Job, DynamicProcessor, MssqlDestination } from '../src';
import { IMssqlDbConnection } from '../src/types';
import * as utils from '../src/utils';

let db: any = null;
const connection: IMssqlDbConnection = {
    user: 'sa',
    password: 'Passw0rd*',
    server: 'mssql',
    database: 'tempdb',
    options: {
        trustServerCertificate: true,
    }
};


describe.each(['tedious', 'msnodesqlv8'])('different drivers', (driverName) => {

    beforeAll(async () => {
        if (driverName === 'msnodesqlv8') {
            connection.driver = await import('mssql/msnodesqlv8');
        }
    });

    beforeEach(async () => {
        db = await utils.getDb(connection, 'mssql');
        await db.query(`DROP TABLE IF EXISTS test_sources`);
        await db.query(`CREATE TABLE test_sources
        (
            id integer
        )`);
    });

    afterEach(async () => {
        await utils.closeDbConnection(connection);
    })

    it(`inserts generated data to mssql using ${driverName} driver`, async () => {
        const processor = new DynamicProcessor({
            generator: async function* () {
                yield {
                    id: 1,
                }
            },
        });
        const destination = new MssqlDestination({
            connection,
            table: 'test_sources',
            batchSize: 1,
        });
        const job = new Job(processor, [destination]);
        await job.run();
        const res = await db.query(`select * from test_sources`);
        expect(res.recordset).toEqual([{
            id: 1,
        }]);
    });
});