Skip to content

Commit b27ca01

Browse files
committed
Fix linebreaks in generated SQL
1 parent 9443a45 commit b27ca01

File tree

1 file changed

+13
-3
lines changed

1 file changed

+13
-3
lines changed

src/database/schemas.ts

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -220,11 +220,21 @@ export default class Schemas {
220220
* @param object Not user input
221221
*/
222222
static async generateSQL(schema: string, object: string, internalType: string): Promise<string> {
223-
const lines = await JobManager.runSQL<{ SRCDTA: string }>([
224-
`CALL QSYS2.GENERATE_SQL(?, ?, ?, CREATE_OR_REPLACE_OPTION => '1', PRIVILEGES_OPTION => '0')`
223+
await JobManager.runSQL<{ SRCDTA: string }>([
224+
`CALL QSYS2.GENERATE_SQL( DATABASE_OBJECT_NAME => ?, DATABASE_OBJECT_LIBRARY_NAME => ?, DATABASE_OBJECT_TYPE => ?
225+
, CREATE_OR_REPLACE_OPTION => '1', PRIVILEGES_OPTION => '0'
226+
, DATABASE_SOURCE_FILE_NAME => '*STMF'
227+
, STATEMENT_FORMATTING_OPTION => '0'
228+
, SOURCE_STREAM_FILE => '/tmp/Q_GENSQL_' concat current_user concat '.sql'
229+
, SOURCE_STREAM_FILE_END_OF_LINE => 'LF'
230+
, SOURCE_STREAM_FILE_CCSID => 1208 )`
225231
].join(` `), { parameters: [object, schema, internalType] });
232+
const lines = await JobManager.runSQL<{ LINE: string }>(
233+
`select LINE
234+
from table( QSYS2.IFS_READ( PATH_NAME => '/tmp/Q_GENSQL_' concat current_user concat '.sql' ) )`
235+
);
226236

227-
const generatedStatement = lines.map(line => line.SRCDTA).join(`\n`);
237+
const generatedStatement = lines.map( elem => elem.LINE ).join(`\n`);
228238

229239
return generatedStatement;
230240
}

0 commit comments

Comments
 (0)