1- import { QueryResultHeader , QueryRowBasedResult } from 'types/SqlResult' ;
1+ import { QueryResult , QueryResultHeader } from 'types/SqlResult' ;
22import { DatabaseSchema } from 'types/SqlSchema' ;
33import { ResultChangeCollectorItem } from './ResultChangeCollector' ;
44import { SqlStatementPlan } from 'types/SqlStatement' ;
@@ -66,7 +66,7 @@ export function getUpdatableTable(
6666
6767function getSqlPlanFromChange (
6868 change : ResultChangeCollectorItem ,
69- data : QueryRowBasedResult ,
69+ data : QueryResult ,
7070 updatable : UpdatableTableDict
7171) : SqlStatementPlan [ ] {
7272 const changedTable : Record < string , SqlStatementPlan > = { } ;
@@ -92,7 +92,8 @@ function getSqlPlanFromChange(
9292 where : updatable [ tableName ] . reduce ( ( a , b ) => {
9393 return {
9494 ...a ,
95- [ b . columnNames ] : data . rows [ change . row ] [ b . columnNumber ] ,
95+ [ b . columnNames ] :
96+ data . rows [ change . row ] [ headers [ b . columnNumber ] . name ] ,
9697 } ;
9798 } , { } ) ,
9899 } ;
@@ -106,7 +107,7 @@ function getSqlPlanFromChange(
106107
107108export default function generateSqlFromChanges (
108109 schema : DatabaseSchema ,
109- currentData : QueryRowBasedResult ,
110+ currentData : QueryResult ,
110111 changes : ResultChangeCollectorItem [ ]
111112) : SqlStatementPlan [ ] {
112113 const updatableTables = getUpdatableTable ( currentData . headers , schema ) ;
0 commit comments