Smart Processes Management
Microsoft SQL Server executor for Runnerty:
Through NPM
npm i @runnerty/executor-sqlserver
You can also add modules to your project with runnerty
npx runnerty add @runnerty/executor-sqlserver
This command installs the module in your project, adds example configuration in your config.json and creates an example plan of use.
If you have installed runnerty globally you can include the module with this command:
runnerty add @runnerty/executor-sqlserver
Add in config.json:
{
"id": "sqlserver_default",
"type": "@runnerty-executor-sqlserver",
"user": "sa",
"password": "yourStrong(!)Password",
"database": "master",
"server": "localhost",
"port": 1433
}
{
"id": "sqlserver_default",
"type": "@runnerty-executor-sqlserver",
"user": "sa",
"password": "yourStrong(!)Password",
"database": "master",
"server": "localhost",
"port": 1433,
"options": {
"useUTC": true
}
}
Parameter | Description |
---|---|
user | The sqlserver user to authenticate as. |
password | The password of that sqlserver user. |
database | Name of the database to use for this connection. (Optional) |
server | The hostname of the database you are connecting to. |
port | The port number to connect to. (Default: 3306) |
domain | Once you set domain, driver will connect to SQL Server using domain login. |
connectionTimeout | Connection timeout in ms (default: 15000). |
requestTimeout | Request timeout in ms (default: 15000). |
pool.max | The maximum number of connections there can be in the pool (default: 10). |
pool.min | The minimum of connections there can be in the pool (default: 0). |
pool.idleTimeoutMillis | The Number of milliseconds before closing an unused connection default: 30000). |
options | get more information about the options in the module documentation node-mssql |
Add in plan.json:
{
"id": "sqlserver_default",
"command_file": "/etc/runnerty/sql/test.sql"
}
{
"id": "sqlserver_default",
"command": "SELECT NOW()"
}
The saved can be indicated in the file of the results obtained from a query in csv, xlsx and json format. These files will be generated with streams. You only have to indicate the corresponding property in the parameters:
XLSX Format
Parameter | Description |
---|---|
xlsxFileExport | Path of xlsx file export. |
xlsxAuthorName | Author file name. (Optional) |
xlsxSheetName | Name of the sheet. (Optional) |
Sample:
{
"id": "sqlserver_default",
"command": "SELECT * FROM USERS",
"xlsxFileExport": "./my_output.xlsx",
"xlsxAuthorName": "Runnerty",
"xlsxSheetName": "MySheetSample"
}
CSV Format
Parameter | Description |
---|---|
csvFileExport | Path of csv file export. |
csvOptions/headers | Type: boolean/string[]. The headers will be auto detected from the first row or you can to provide headers array: ['h1name','h2name',...]. |
csvOptions/delimiter | Alternate delimiter. (Default: ',') |
csvOptions/quote | Alternate quote. (Default: '"') |
csvOptions/alwaysWriteHeaders | Set to true if you always want headers written, even if no rows are written. (Default: false) |
csvOptions/rowDelimiter | Specify an alternate row delimiter (i.e \r\n). (Default: '\n') |
csvOptions/quoteHeaders | If true then all headers will be quoted. (Default: quoteColumns value) |
csvOptions/quoteColumns | If true then columns and headers will be quoted (unless quoteHeaders is specified). (Default: false). More info here. |
csvOptions/escape | Alternate escaping value. (Default: '"') |
csvOptions/includeEndRowDelimiter | Set to true to include a row delimiter at the end of the csv. (Default: false) |
csvOptions/writeBOM | Set to true if you want the first character written to the stream to be a utf-8 BOM character. (Default: false) |
Sample:
{
"id": "sqlserver_default",
"command": "SELECT * FROM USERS",
"csvFileExport": "@GV(WORK_DIR)/users.csv",
"csvOptions": {
"delimiter": ";",
"quote": "\""
}
}
JSON Format
Sample:
{
"id": "sqlserver_sample",
"command": "SELECT * FROM USERS",
"fileExport": "@GV(WORK_DIR)/users.json"
}
For file upload you must indicate the path of the file to be loaded in the localInFile
parameter and in the LOAD DATA LOCAL INFILE
statement you must indicate mystream
. For example:
localInFile
: Plain file path
{
"id": "sqlserver_default",
"command": "LOAD DATA LOCAL INFILE 'mystream' INTO TABLE DBSAMPLE.TABLESAMPLE FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n'",
"localInFile": "/sample.csv"
}
PROCESS_EXEC_MSG_OUTPUT
: sqlserver output message.PROCESS_EXEC_ERR_OUTPUT
: Error output message.
PROCESS_EXEC_DATA_OUTPUT
: sqlserver query output data.PROCESS_EXEC_DB_COUNTROWS
: sqlserver query count rows.PROCESS_EXEC_DB_FIRSTROW
: sqlserver query first row data.PROCESS_EXEC_DB_FIRSTROW_[FILED_NAME]
: sqlserver first row field data.
If the process executes more than one query, it will be able to access its first row indicating its number in order, starting at zero. The first query corresponds to PROCESS_EXEC_DB_FIRSTROW
, the next to PROCESS_EXEC_DB_FIRSTROW_1
and so on.
The same is true for the rest of the values.
PROCESS_EXEC_DB_AFFECTEDROWS
: sqlserver affected rows count.
If the process executes more than one operation, it will be able to access its first row indicating its number in order, starting at zero. The first operation corresponds to PROCESS_EXEC_DB_AFFECTEDROWS
, the next to PROCESS_EXEC_DB_AFFECTEDROWS_1
and so on.