npm package diff

Package: @forge/sql

Versions: 2.2.3 - 2.3.0-next.0

File: package/out/__test__/migration.test.js

Index: package/out/__test__/migration.test.js
===================================================================
--- package/out/__test__/migration.test.js
+++ package/out/__test__/migration.test.js
@@ -37,27 +37,27 @@
     });
     describe('list', () => {
         it('should list all previously migrations', async () => {
             const migratedAtDate = new Date();
-            mockSqlClient.executeRaw.mockResolvedValueOnce({
+            mockSqlClient.executeDDL.mockResolvedValueOnce({
                 rows: [{ id: 1, name: 'create-table-test', migratedAt: migratedAtDate }]
             });
             const migrations = await migrationRunner.list();
             expect(migrations.length).toBe(1);
             expect(migrations[0]).toEqual({ id: 1, name: 'create-table-test', migratedAt: migratedAtDate });
-            expect(mockSqlClient.executeRaw).toHaveBeenCalledWith('SELECT id, name, migratedAt FROM __migrations;');
+            expect(mockSqlClient.executeDDL).toHaveBeenCalledWith('SELECT id, name, migratedAt FROM __migrations;');
         });
         it('should be empty when no previous migrations exist', async () => {
-            mockSqlClient.executeRaw.mockResolvedValueOnce({
+            mockSqlClient.executeDDL.mockResolvedValueOnce({
                 rows: []
             });
             const migrations = await migrationRunner.list();
             expect(migrations.length).toBe(0);
-            expect(mockSqlClient.executeRaw).toHaveBeenCalledWith('SELECT id, name, migratedAt FROM __migrations;');
+            expect(mockSqlClient.executeDDL).toHaveBeenCalledWith('SELECT id, name, migratedAt FROM __migrations;');
         });
         it('should raise an error when schema version table does not exist', async () => {
             const tableDoesNotExistError = new Error(errorCodes_1.errorCodes.SQL_EXECUTION_ERROR);
-            mockSqlClient.executeRaw.mockRejectedValue(tableDoesNotExistError);
+            mockSqlClient.executeDDL.mockRejectedValue(tableDoesNotExistError);
             await expect(migrationRunner.list()).rejects.toThrow(tableDoesNotExistError);
         });
     });
     describe('run', () => {
@@ -71,12 +71,12 @@
         describe('when few migrations have been successfully run in the past', () => {
             it('should execute migrations that have not been previously run', async () => {
                 migrationRunner.enqueue('v_001_create_table_foo', CREATE_TABLE_FOO_QUERY);
                 migrationRunner.enqueue('v_002_create_table_bar', CREATE_TABLE_BAR_QUERY);
-                (0, jest_when_1.when)(mockSqlClient.executeRaw)
+                (0, jest_when_1.when)(mockSqlClient.executeDDL)
                     .calledWith((0, jest_when_1.when)((arg) => arg.startsWith('CREATE TABLE IF NOT EXISTS __migrations')))
                     .mockResolvedValue({ rows: [] });
-                (0, jest_when_1.when)(mockSqlClient.executeRaw)
+                (0, jest_when_1.when)(mockSqlClient.executeDDL)
                     .calledWith('SELECT id, name, migratedAt FROM __migrations;')
                     .mockResolvedValue({
                     rows: [{ name: 'v_001_create_table_foo', statement: CREATE_TABLE_FOO_QUERY, migratedAt: new Date() }]
                 });
@@ -89,20 +89,20 @@
                     .mockReturnValue(new sql_statement_1.SqlStatement(insertMigrationVersionQueryTemplate, mockApiCall));
                 const result = await migrationRunner.run();
                 expect(result).toEqual(['v_002_create_table_bar']);
                 expect(mockSqlClient.prepare).toHaveBeenCalledTimes(1);
-                expect(mockSqlClient.executeRaw).toHaveBeenCalledTimes(3);
+                expect(mockSqlClient.executeDDL).toHaveBeenCalledTimes(3);
             });
         });
         describe('when no migrations have been run in the past', () => {
             it('should execute migrations that have not been previously run', async () => {
                 const CREATE_TABLE_FOO_QUERY = 'CREATE TABLE IF NOT EXISTS foo (id INT)';
                 migrationRunner.enqueue('v_001_create_table_foo', CREATE_TABLE_FOO_QUERY);
                 migrationRunner.enqueue('v_002_create_table_bar', 'CREATE TABLE IF NOT EXISTS bar (id INT)');
-                (0, jest_when_1.when)(mockSqlClient.executeRaw).calledWith('SELECT id, name, migratedAt FROM __migrations;').mockResolvedValue({
+                (0, jest_when_1.when)(mockSqlClient.executeDDL).calledWith('SELECT id, name, migratedAt FROM __migrations;').mockResolvedValue({
                     rows: []
                 });
-                (0, jest_when_1.when)(mockSqlClient.executeRaw)
+                (0, jest_when_1.when)(mockSqlClient.executeDDL)
                     .calledWith((0, jest_when_1.when)((arg) => arg.startsWith('CREATE TABLE IF NOT EXISTS __migrations')))
                     .mockResolvedValue({ rows: [] });
                 const mockApiCall = jest.fn();
                 (0, jest_when_1.when)(mockApiCall)
@@ -113,9 +113,9 @@
                     .mockReturnValue(new sql_statement_1.SqlStatement(insertMigrationVersionQueryTemplate, mockApiCall));
                 const result = await migrationRunner.run();
                 expect(result).toEqual(['v_001_create_table_foo', 'v_002_create_table_bar']);
                 expect(mockSqlClient.prepare).toHaveBeenCalledTimes(2);
-                expect(mockSqlClient.executeRaw).toHaveBeenCalledTimes(4);
+                expect(mockSqlClient.executeDDL).toHaveBeenCalledTimes(4);
             });
         });
     });
 });