• Module "./sqlmath.mjs"
  • 1. function assertErrorThrownAsync(asyncFunc, regexp)
  • 2. function assertInt64(val)
  • 3. function assertJsonEqual(aa, bb, message)
  • 4. function assertNumericalEqual(aa, bb, message)
  • 5. function assertOrThrow(condition, message)
  • 6. function childProcessSpawn2(command, args, option)
  • 7. function ciBuildExt({ process })
  • 8. function dbCloseAsync(db)
  • 9. function dbExecAndReturnLastBlob(option)
  • 10. function dbExecAndReturnLastRow(option)
  • 11. function dbExecAndReturnLastTable(option)
  • 12. function dbExecAndReturnLastValue(option)
  • 13. function dbExecAsync({ bindList = [], db, modeNoop, responseType, sql })
  • 14. function dbExecProfile({ limit = 20, lineLength = 80, modeInit, sqlLength = 256 })
  • 15. function dbFileLoadAsync({ db, dbData, filename, modeNoop, modeSave = 0 })
  • 16. function dbFileSaveAsync({ db, dbData, filename, modeNoop })
  • 17. function dbNoopAsync(...argList)
  • 18. function dbOpenAsync({ afterFinalization, dbData, filename = ":memory:", flags, threadCount = 1, timeoutBusy = 5000 })
  • 19. function dbTableImportAsync({ db, filename, headerMissing, mode, tableName, textData })
  • 20. function debugInline(...argv)
  • 21. function fsCopyFileUnlessTest(file1, file2, mode)
  • 22. function fsExistsUnlessTest(file, mode)
  • 23. function fsReadFileUnlessTest(file, mode, defaultData)
  • 24. function fsWriteFileUnlessTest(file, data, mode)
  • 25. function jsbatonGetInt64(baton, argi)
  • 26. function jsbatonGetString(baton, argi)
  • 27. function listOrEmptyList(list)
  • 28. function noop(val)
  • 29. function objectDeepCopyWithKeysSorted(obj)
  • 30. function sqlmathWebworkerInit({ db, modeTest })
  • 31. function waitAsync(timeout)
  • 32. number LGBM_DTYPE_FLOAT32
  • 33. number LGBM_DTYPE_FLOAT64
  • 34. number LGBM_DTYPE_INT32
  • 35. number LGBM_DTYPE_INT64
  • 36. number LGBM_FEATURE_IMPORTANCE_GAIN
  • 37. number LGBM_FEATURE_IMPORTANCE_SPLIT
  • 38. number LGBM_MATRIX_TYPE_CSC
  • 39. number LGBM_MATRIX_TYPE_CSR
  • 40. number LGBM_PREDICT_CONTRIB
  • 41. number LGBM_PREDICT_LEAF_INDEX
  • 42. number LGBM_PREDICT_NORMAL
  • 43. number LGBM_PREDICT_RAW_SCORE
  • 44. number SQLITE_OPEN_AUTOPROXY
  • 45. number SQLITE_OPEN_CREATE
  • 46. number SQLITE_OPEN_DELETEONCLOSE
  • 47. number SQLITE_OPEN_EXCLUSIVE
  • 48. number SQLITE_OPEN_FULLMUTEX
  • 49. number SQLITE_OPEN_MAIN_DB
  • 50. number SQLITE_OPEN_MAIN_JOURNAL
  • 51. number SQLITE_OPEN_MEMORY
  • 52. number SQLITE_OPEN_NOFOLLOW
  • 53. number SQLITE_OPEN_NOMUTEX
  • 54. number SQLITE_OPEN_PRIVATECACHE
  • 55. number SQLITE_OPEN_READONLY
  • 56. number SQLITE_OPEN_READWRITE
  • 57. number SQLITE_OPEN_SHAREDCACHE
  • 58. number SQLITE_OPEN_SUBJOURNAL
  • 59. number SQLITE_OPEN_SUPER_JOURNAL
  • 60. number SQLITE_OPEN_TEMP_DB
  • 61. number SQLITE_OPEN_TEMP_JOURNAL
  • 62. number SQLITE_OPEN_TRANSIENT_DB
  • 63. number SQLITE_OPEN_URI
  • 64. number SQLITE_OPEN_WAL
  • 65. object DB_EXEC_PROFILE_DICT
  • 66. string SQLMATH_EXE
  • 67. string SQLMATH_NODE
  • 68. string version

Module "./sqlmath.mjs"

• 1. function assertErrorThrownAsync(asyncFunc, regexp)

• Description and source-code:

  async function assertErrorThrownAsync(asyncFunc, regexp) {
  
  // This function will assert calling <asyncFunc> throws an error.
  
      let err;
      try {
          await asyncFunc();
      } catch (errCaught) {
          err = errCaught;
      }
      assertOrThrow(err, "No error thrown.");
      assertOrThrow(
          !regexp || new RegExp(regexp).test(err.message),
          err
      );
  }

• Example usage:

  ...
              [1, "1"],
              [0, undefined]
          ];
          await Promise.all([
              (async function () {
  let valActual;
  // test win_sum2-error handling-behavior
  await assertErrorThrownAsync(function () {
      return dbExecAsync({
          db,
          sql: (`
  SELECT WIN_SUM2() FROM (SELECT 1);
          `)
      });
  }, "wrong number of arguments");
  ...

• 2. function assertInt64(val)

• Description and source-code:

  function assertInt64(val) {
      // This function will assert <val> is within range of c99-signed-long-long.
      val = BigInt(val);
      if (!(
          -9_223_372_036_854_775_808n <= val && val <= 9_223_372_036_854_775_807n
      )) {
          throw new Error(
              `integer ${val} outside signed-64-bit inclusive-range`
              + " -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807"
          );
      }
  }

• Example usage:

  ...
          referenceList.push(val);
          break;
      case SQLITE_DATATYPE_FLOAT:
          // push SQLITE-REAL - 8-byte
          baton.setFloat64(nused + 1, val, true);
          break;
      case SQLITE_DATATYPE_INTEGER:
          assertInt64(val);
          // push SQLITE-INTEGER - 8-byte
          baton.setBigInt64(nused + 1, val, true);
          break;
      }
      return baton;
  }
  ...

• 3. function assertJsonEqual(aa, bb, message)

• Description and source-code:

  function assertJsonEqual(aa, bb, message) {
  
  // This function will assert JSON.stringify(<aa>) === JSON.stringify(<bb>).
  
      aa = JSON.stringify(objectDeepCopyWithKeysSorted(aa), undefined, 1);
      bb = JSON.stringify(objectDeepCopyWithKeysSorted(bb), undefined, 1);
      if (aa !== bb) {
          throw new Error(
              "\n" + aa + "\n!==\n" + bb
              + (
                  typeof message === "string"
                  ? " - " + message
                  : message
                  ? " - " + JSON.stringify(message)
                  : ""
              )
          );
      }
  }

• Example usage:

  ...
  CREATE TEMP TABLE __tmp1 (val REAL);
  SELECT WIN_SUM1(1) FROM __tmp1;
                      `)
                  });
                  valActual = valActual.map(function ({val}) {
                      return val;
                  });
                  assertJsonEqual(valActual, [null]);
                  // test win_sum2-null-case handling-behavior
                  valActual = await dbExecAndReturnLastTable({
                      db,
                      sql: (`
  DROP TABLE IF EXISTS __tmp1;
  CREATE TEMP TABLE __tmp1 (val REAL);
  SELECT DOUBLEARRAY_JSONTO(WIN_SUM2(1, 2, 3)) FROM __tmp1;
  ...

• 4. function assertNumericalEqual(aa, bb, message)

• Description and source-code:

  function assertNumericalEqual(aa, bb, message) {
  
  // This function will assert aa - bb <= Number.EPSILON.
  
      assertOrThrow(aa, "value cannot be 0 or falsy");
      if (!(Math.abs((aa - bb) / Math.max(aa, bb)) <= 256 * Number.EPSILON)) {
          throw new Error(
              JSON.stringify(aa) + " != " + JSON.stringify(bb) + (
                  message
                  ? " - " + message
                  : ""
              )
          );
      }
  }

• Example usage:

  ...
  jstestDescribe((
  "test_assertXxx"
  ), function test_assertXxx() {
  jstestIt((
      "test assertXxx handling-behavior"
  ), function () {
      assertErrorThrownAsync(function () {
          assertNumericalEqual(0, 0);
      }, "value cannot be 0 or falsy");
      assertErrorThrownAsync(function () {
          assertNumericalEqual(1, 2);
      }, "1 != 2");
      assertErrorThrownAsync(function () {
          assertNumericalEqual(1, 2, "aa");
      }, "aa");
  ...

• 5. function assertOrThrow(condition, message)

• Description and source-code:

  function assertOrThrow(condition, message) {
  
  // This function will throw <message> if <condition> is falsy.
  
      if (!condition) {
          throw (
              (!message || typeof message === "string")
              ? new Error(String(message).slice(0, 2048))
              : message
          );
      }
  }

• Example usage:

  ...
              db,
              sql: (`
  SELECT DOUBLEARRAY_JSONTO(DOUBLEARRAY_JSONFROM($valIn)) AS result;
              `)
          })
      ).result;
  } catch (ignore) {
      assertOrThrow(valExpect === "error", JSON.stringify({
          ii,
          valActual,
          valExpect,
          valIn
      }, undefined, 4));
      return;
  }
  ...

• 6. function childProcessSpawn2(command, args, option)

• Description and source-code:

  async function childProcessSpawn2(command, args, option) {
  
  // This function will run child_process.spawn as a promise.
  
      return await new Promise(function (resolve, reject) {
          let bufList = [[], [], []];
          let child;
          let {
              modeCapture,
              modeDebug,
              stdio = []
          } = option;
          if (modeDebug) {
              consoleError(
                  `childProcessSpawn2 - ${command} ${JSON.stringify(args)}`
              );
          }
          child = moduleChildProcessSpawn(
              command,
              args,
              Object.assign({}, option, {
                  stdio: [
                      "ignore",
                      (
                          modeCapture
                          ? "pipe"
                          : stdio[1]
                      ),
                      (
                          modeCapture
                          ? "pipe"
                          : stdio[2]
                      )
                  ]
              })
          );
          if (modeCapture) {
              [
                  child.stdin, child.stdout, child.stderr
              ].forEach(function (pipe, ii) {
                  if (ii === 0) {
                      return;
                  }
                  pipe.on("data", function (chunk) {
                      bufList[ii].push(chunk);
                      if (stdio[ii] !== "ignore") {
                          switch (ii) {
                          case 1:
                              process.stdout.write(chunk);
                              break;
                          case 2:
                              process.stderr.write(chunk);
                              break;
                          }
                      }
                  });
              });
          }
          child.on("exit", function (exitCode) {
              let resolve0 = resolve;
              let stderr;
              let stdout;
              // coverage-hack
              if (exitCode || npm_config_mode_test) {
                  resolve = reject;
           ...
  }
  

• Example usage:

  ...
  jstestDescribe((
  "test_childProcessSpawn2"
  ), function test_childProcessSpawn2() {
  jstestIt((
      "test childProcessSpawn2 handling-behavior"
  ), async function () {
      await Promise.all([
          childProcessSpawn2(
              "undefined",
              [],
              {modeCapture: "utf8", modeDebug: true, stdio: []}
          ),
          (async function () {
              let result;
              result = await moduleUtil.promisify(
  ...

• 7. function ciBuildExt({ process })

• Description and source-code:

  async function ciBuildExt({
      process
  }) {
  
  // This function will build sqlmath from c.
  
      let binNodegyp;
      let exitCode;
      binNodegyp = modulePath.resolve(
          modulePath.dirname(process.execPath || ""),
          "node_modules/npm/node_modules/node-gyp/bin/node-gyp.js"
      ).replace("/bin/node_modules/", "/lib/node_modules/");
      if (!noop(
          await fsExistsUnlessTest(cModulePath)
      )) {
          await ciBuildExt1NodejsConfigure({
              binNodegyp,
              process
          });
      }
      consoleError(
          `ciBuildExt2Nodejs - linking lib ${modulePath.resolve(cModulePath)}`
      );
      [
          exitCode
      ] = await childProcessSpawn2(
          "sh",
          [
              "-c",
              (`
  (set -e
      # rebuild binding
      rm -rf build/Release/obj/SRC_SQLMATH_CUSTOM/
      node "${binNodegyp}" build --release
      # node "${binNodegyp}" build --release --loglevel=verbose
      mv build/Release/binding.node "${cModulePath}"
      mv build/Release/shell "${SQLMATH_EXE}"
      # ugly-hack - win32-sqlite-shell doesn't like nodejs-builtin-zlib,
      #             so link with external-zlib.
      if (uname | grep -q "MING\\|MSYS")
      then
          rm -f ${SQLMATH_EXE}
          python setup.py exe_link \
              ./build/Release/SRC_SQLITE_BASE.lib \
              ./build/Release/SRC_SQLMATH_CUSTOM.lib \
              ./build/Release/obj/shell/sqlmath_external_sqlite.obj \
              ./zlib.v1.3.1.vcpkg.x64-windows-static.lib \
              \
              -ltcg \
              -nologo \
              -out:${SQLMATH_EXE} \
              -subsystem:console
      fi
  )
              `)
          ],
          {modeDebug: npm_config_mode_debug, stdio: ["ignore", 1, 2]}
      );
      assertOrThrow(!exitCode, `ciBuildExt - exitCode=${exitCode}`);
  }

• Example usage:

  ...
  jstestDescribe((
  "test_ciBuildExtXxx"
  ), function test_ciBuildExtXxx() {
  jstestIt((
      "test ciBuildExt handling-behavior"
  ), async function () {
      await Promise.all([
          ciBuildExt({process: {arch: "arm", env: {}, platform: "win32"}}),
          ciBuildExt({process: {arch: "arm64", env: {}, platform: "win32"}}),
          ciBuildExt({process: {arch: "ia32", env: {}, platform: "win32"}}),
          ciBuildExt({process: {cwd: noop}}),
          ciBuildExt({process: {env: {}, platform: "darwin"}}),
          ciBuildExt({process: {env: {}, platform: "win32"}}),
          ciBuildExt({process: {versions: {}}})
      ]);
  ...

• 8. function dbCloseAsync(db)

• Description and source-code:

  async function dbCloseAsync(db) {
  
  // This function will close sqlite-database-connection <db>.
  
      // prevent segfault - do not close db if actions are pending
      assertOrThrow(
          db.busy === 0,
          `dbCloseAsync - cannot close db with ${db.busy} actions pending`
      );
      // cleanup connPool
      await Promise.all(db.connPool.map(async function (ptr) {
          let val = ptr[0];
          ptr[0] = 0n;
          await dbCallAsync(
              jsbatonCreate("_dbClose"),
              [
                  val,
                  db.filename
              ]
          );
      }));
  }

• Example usage:

  ...
                  ) >= 0,
                  err
              );
          }
      });
      // test close-while-busy handling-behavior
      assertErrorThrownAsync(function () {
          return dbCloseAsync(db);
      }, "cannot close db");
  });
  jstestIt((
      "test dbFileXxx handling-behavior"
  ), async function test_dbFileXxx() {
      let data;
      let db = await dbOpenAsync({});
  ...

• 9. function dbExecAndReturnLastBlob(option)

• Description and source-code:

  function dbExecAndReturnLastBlob(option) {
  
  // This function will exec <sql> in <db>,
  // and return last-value retrieved from execution as raw blob/buffer.
  
      return dbExecAsync(Object.assign({
          responseType: "lastblob"
      }, option));
  }

• Example usage:

  ...
          })
      ),
      []
  );
  // test dbExecAndReturnLastBlob null-case handling-behavior
  assertJsonEqual(
      new TextDecoder().decode(
          await dbExecAndReturnLastBlob({
              db,
              sql: "SELECT 0 WHERE 0"
          })
      ),
      ""
  );
  // test dbExecAndReturnLastBlob string handling-behavior
  ...

• 10. function dbExecAndReturnLastRow(option)

• Description and source-code:

  async function dbExecAndReturnLastRow(option) {
  
  // This function will exec <sql> in <db>,
  // and return last-row or empty-object.
  
      let result = await dbExecAsync(option);
      result = result[result.length - 1] || [];
      result = result[result.length - 1] || {};
      return result;
  }

• Example usage:

  ...
                  "rra": 0,
                  "rrb": -1.63694722,
                  "xxa": 34,
                  "xxb": 51,
                  "yya": 5,
                  "yyb": 5
              };
              valActual = await dbExecAndReturnLastRow({
                  db,
                  sql: (`
  SELECT
      ${sqlSinefitExtractLnr("__wsf", 0, "")}
  FROM (
      SELECT
          WIN_SINEFIT2(1, NULL, xx, yy) AS __wsf
  ...

• 11. function dbExecAndReturnLastTable(option)

• Description and source-code:

  async function dbExecAndReturnLastTable(option) {
  
  // This function will exec <sql> in <db>,
  // and return last-table or empty-list.
  
      let result = await dbExecAsync(option);
      result = result[result.length - 1] || [];
      return result;
  }

• Example usage:

  ...
          db,
          sql: (`
  SELECT WIN_SUM2() FROM (SELECT 1);
          `)
      });
  }, "wrong number of arguments");
  // test win_sum1-null-case handling-behavior
  valActual = await dbExecAndReturnLastTable({
      db,
      sql: (`
  DROP TABLE IF EXISTS __tmp1;
  CREATE TEMP TABLE __tmp1 (val REAL);
  SELECT WIN_SUM1(1) FROM __tmp1;
      `)
  });
  ...

• 12. function dbExecAndReturnLastValue(option)

• Description and source-code:

  function dbExecAndReturnLastValue(option) {
  
  // This function will exec <sql> in <db>,
  // and return last-json-value.
  
      return dbExecAsync(Object.assign({
          responseType: "lastvalue"
      }, option));
  }

• Example usage:

  ...
  let valActual;
  sql = (
      func === "SHA256"
      ? `SELECT HEX(${func}(${arg}))`
      : `SELECT ${func}(${arg})`
  );
  valActual = noop(
      await dbExecAndReturnLastValue({
          db,
          sql
      })
  );
  assertJsonEqual(valActual, valExpect, {
      sql,
      valExpect
  ...

• 13. function dbExecAsync({ bindList = [], db, modeNoop, responseType, sql })

• Description and source-code:

  async function dbExecAsync({
      bindList = [],
      db,
      modeNoop,
      responseType,
      sql
  }) {
  
  // This function will exec <sql> in <db> and return <result>.
  
      let baton = jsbatonCreate("_dbExec");
      let bindByKey = !Array.isArray(bindList);
      let bufi = [0];
      let referenceList = [];
      let result;
      if (modeNoop) {
          return;
      }
      if (bindByKey) {
          Object.entries(bindList).forEach(function ([key, val]) {
              baton = jsbatonSetValue(baton, undefined, `:${key}\u0000`);
              baton = jsbatonSetValue(
                  baton,
                  undefined,
                  val,
                  bufi,
                  referenceList
              );
          });
      } else {
          bindList.forEach(function (val) {
              baton = jsbatonSetValue(
                  baton,
                  undefined,
                  val,
                  bufi,
                  referenceList
              );
          });
      }
      [
          baton, ...result
      ] = await dbCallAsync(
          baton,
          [
              // 0. db
              db,
              // 1. sql
              String(sql) + "\n;\nPRAGMA noop",
              // 2. bindList.length
              (
                  bindByKey
                  ? Object.keys(bindList).length
                  : bindList.length
              ),
              // 3. bindByKey
              bindByKey,
              // 4. responseType
              (
                  responseType === "lastblob"
                  ? SQLITE_RESPONSETYPE_LASTBLOB
                  : responseType === "lastvalue"
                  ? SQLITE_RESPONSETYPE_LASTVALUE
                  : 0
              )
          ],
          "modeDbExec"
      );
      result = result[0];
      if (!IS_BROWSER) {
          result = cModule._jsbatonStealCbuffer(
              baton.buffer,
              0,
              Number(
                  responseType !== "arraybuffer" && responseType !== "lastblob"
              )
          );
      }
      switch (responseType) {
      case "arraybuffer"...
  }
  

• Example usage:

  ...
              [0, undefined]
          ];
          await Promise.all([
              (async function () {
  let valActual;
  // test win_sum2-error handling-behavior
  await assertErrorThrownAsync(function () {
      return dbExecAsync({
          db,
          sql: (`
  SELECT WIN_SUM2() FROM (SELECT 1);
          `)
      });
  }, "wrong number of arguments");
  // test win_sum1-null-case handling-behavior
  ...

• 14. function dbExecProfile({ limit = 20, lineLength = 80, modeInit, sqlLength = 256 })

• Description and source-code:

  function dbExecProfile({
      limit = 20,
      lineLength = 80,
      modeInit,
      sqlLength = 256
  }) {
  
  // This function will profile dbExecAsync.
  
      let result;
      if (modeInit && !DB_EXEC_PROFILE_MODE) {
          DB_EXEC_PROFILE_MODE = Date.now();
          DB_EXEC_PROFILE_SQL_LENGTH = sqlLength;
          process.on("exit", function () {
              console.error(dbExecProfile({
                  limit,
                  lineLength
              }));
          });
          return;
      }
      result = Object.values(DB_EXEC_PROFILE_DICT);
      result.sort(function (aa, bb) {
          return ((bb.timeElapsed - aa.timeElapsed) || (bb.count - aa.count));
      });
      result = result.slice(0, limit).map(function ({
          count,
          sql,
          timeElapsed
      }, ii) {
          return String(
              `${Number(ii + 1).toFixed(0).padStart(2, " ")}.`
              + ` ${timeElapsed.toFixed(0).padStart(4)}`
              + ` ${count.toFixed(0).padStart(3)}`
              + " " + JSON.stringify(sql)
          ).slice(0, lineLength);
      }).join("\n");
      result = (
          `\ndbExecProfile:\n`
          + ` #  time cnt sql\n`
          + `${result}\n`
      );
      return result;
  }

• Example usage:

  ...
  jstestDescribe,
  jstestIt
  } = jslint;
  let {
  npm_config_mode_test_save
  } = process.env;
  
  dbExecProfile({
  modeInit: true
  });
  
  jstestDescribe((
  "test_apidoc"
  ), function test_apidoc() {
  jstestIt((
  ...

• 15. function dbFileLoadAsync({ db, dbData, filename, modeNoop, modeSave = 0 })

• Description and source-code:

  async function dbFileLoadAsync({
      db,
      dbData,
      filename,
      modeNoop,
      modeSave = 0
  }) {
  
  // This function will load <filename> to <db>.
  
      let filename2;
      async function _dbFileLoad() {
          dbData = await dbCallAsync(
              jsbatonCreate("_dbFileLoad"),
              [
                  // 0. sqlite3 * pInMemory
                  db,
                  // 1. char *zFilename
                  filename,
                  // 2. const int isSave
                  modeSave,
                  // 3. undefined
                  undefined,
                  // 4. dbData - same position as dbOpenAsync
                  dbData
              ],
              "modeDbFile"
          );
      }
      if (modeNoop) {
          return;
      }
      if (IS_BROWSER) {
          filename = FILENAME_DBTMP;
      }
      assertOrThrow(
          typeof filename === "string" && filename,
          `invalid filename ${filename}`
      );
      db.filename2 = filename;
      // Save to tmpfile and then atomically-rename to actual-filename.
      if (moduleFs && modeSave) {
          filename2 = filename;
          filename = modulePath.join(
              modulePath.dirname(filename),
              `.dbFileSaveAsync.${moduleCrypto.randomUUID()}`
          );
          try {
              await _dbFileLoad();
              await moduleFs.promises.rename(filename, filename2);
          } finally {
              await moduleFs.promises.unlink(filename).catch(noop);
          }
      } else {
          await _dbFileLoad();
      }
      return dbData[1 + 0];
  }

• Example usage:

  ...
      sql: "CREATE TABLE t01 AS SELECT 1 AS c01"
  });
  await dbFileSaveAsync({
      db,
      filename: ".testDbFileXxx.sqlite"
  });
  db = await dbOpenAsync({});
  await dbFileLoadAsync({
      db,
      filename: ".testDbFileXxx.sqlite"
  });
  data = await dbExecAsync({
      db,
      sql: "SELECT * FROM t01"
  });
  ...

• 16. function dbFileSaveAsync({ db, dbData, filename, modeNoop })

• Description and source-code:

  async function dbFileSaveAsync({
      db,
      dbData,
      filename,
      modeNoop
  }) {
  
  // This function will save <db> to <filename>.
  
      return await dbFileLoadAsync({
          db,
          dbData,
          filename,
          modeNoop,
          modeSave: 1
      });
  }

• Example usage:

  ...
          db,
          filename: fileActual,
          headerMissing: true,
          mode: "tsv",
          tableName: "__lgbm_table_preb"
      });
  }
  await dbFileSaveAsync({
      db,
      filename: `.tmp/test_lgbm_${sqlIi}.sqlite`
  });
  assertJsonEqual(
      noop(
          await dbExecAndReturnLastRow({
              db,
  ...

• 17. function dbNoopAsync(...argList)

• Description and source-code:

  async function dbNoopAsync(...argList) {
  
  // This function will do nothing except return <argList>.
  
      return await dbCallAsync(
          jsbatonCreate("_dbNoop"),
          argList
      );
  }

• Example usage:

  ...
      // 8. undefined
      [undefined, 0]
  ].map(async function ([valIn, valExpect], ii) {
      let baton;
      let valActual;
      if (valExpect === Error) {
          assertErrorThrownAsync(function () {
              return dbNoopAsync(undefined, valIn, undefined);
          }, "invalid arg|integer");
          return;
      }
      baton = await dbNoopAsync(undefined, valIn, undefined);
      baton = baton[0];
      valActual = (
          typeof valIn === "string"
  ...

• 18. function dbOpenAsync({ afterFinalization, dbData, filename = ":memory:", flags, threadCount = 1, timeoutBusy = 5000 })

• Description and source-code:

  async function dbOpenAsync({
      afterFinalization,
      dbData,
      filename = ":memory:",
      flags,
      threadCount = 1,
      timeoutBusy = 5000
  }) {
  
  // This function will open and return sqlite-database-connection <db>.
  
  // int sqlite3_open_v2(
  //   const char *filename,   /* Database filename (UTF-8) */
  //   sqlite3 **ppDb,         /* OUT: SQLite db handle */
  //   int flags,              /* Flags */
  //   const char *zVfs        /* Name of VFS module to use */
  // );
      let connPool;
      let db = {busy: 0, filename, ii: 0};
      let libLgbm;
      assertOrThrow(typeof filename === "string", `invalid filename ${filename}`);
      assertOrThrow(
          !dbData || isExternalBuffer(dbData),
          "dbData must be ArrayBuffer"
      );
      connPool = await Promise.all(Array.from(new Array(
          threadCount
      ), async function () {
          let [ptr] = await dbCallAsync(
              jsbatonCreate("_dbOpen"),
              [
                  // 0. const char *filename,   Database filename (UTF-8)
                  filename,
                  // 1. sqlite3 **ppDb,         OUT: SQLite db handle
                  undefined,
                  // 2. int flags,              Flags
                  flags ?? (
                      SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_URI
                  ),
                  // 3. const char *zVfs        Name of VFS module to use
                  undefined,
                  // 4. wasm-only - arraybuffer of raw sqlite-database
                  dbData
              ]
          );
          ptr = [ptr.getBigInt64(JSBATON_OFFSET_ARGV + 0, true)];
          dbFinalizationRegistry.register(db, {afterFinalization, ptr});
          return ptr;
      }));
      db.connPool = connPool;
      if (!IS_BROWSER && !DB_OPEN_INIT) {
          DB_OPEN_INIT = true;
          // init lgbm
          libLgbm = process.platform;
          libLgbm = libLgbm.replace("darwin", "lib_lightgbm.dylib");
          libLgbm = libLgbm.replace("win32", "lib_lightgbm.dll");
          libLgbm = libL...
  }
  

• Example usage:

  ...
  
  jstestDescribe((
  "test_sqlmathWebworkerInit"
  ), function test_sqlmathWebworkerInit() {
  jstestIt((
      "test sqlmathWebworkerInit handling-behavior"
  ), async function () {
      let db = await dbOpenAsync({
          dbData: new ArrayBuffer()
      });
      sqlmathWebworkerInit({
          db,
          modeTest: true
      });
  });
  ...

• 19. function dbTableImportAsync({ db, filename, headerMissing, mode, tableName, textData })

• Description and source-code:

  async function dbTableImportAsync({
      db,
      filename,
      headerMissing,
      mode,
      tableName,
      textData
  }) {
  // this function will create table from imported csv/json <textData>
      let colList;
      let rowList;
      let rowidList;
      let tmp;
      if (filename) {
          textData = await moduleFs.promises.readFile(filename, "utf8");
      }
      switch (mode) {
      case "csv":
          rowList = jsonRowListFromCsv({
              csv: textData
          });
          break;
      case "tsv":
          rowList = [];
          textData.trimEnd().replace((/.+/g), function (line) {
              rowList.push(line.split("\t"));
          });
          break;
      // case "json":
      default:
          rowList = JSON.parse(textData);
      }
      if (!(typeof rowList === "object" && rowList)) {
          rowList = [];
      }
      // normalize rowList to list
      if (!Array.isArray(rowList)) {
          rowidList = [];
          rowList = Object.entries(rowList).map(function ([
              key, val
          ]) {
              rowidList.push(key);
              return val;
          });
      }
      // headerMissing
      if (headerMissing && (rowList.length > 0 && Array.isArray(rowList[0]))) {
          rowList.unshift(Array.from(rowList[0]).map(function (ignore, ii) {
              return String(ii + 1);
          }));
      }
      // normalize rowList[ii] to list
      if (rowList.length === 0) {
          rowList.push([
              "undefined"
          ]);
      }
      if (!Array.isArray(rowList[0])) {
          colList = Array.from(
              new Set(
                  rowList.map(function (obj) {
                      return Object.keys(obj);
                  }).flat()
              )
          );
          rowList = rowList.map(function (obj) {
              return colList.map(function (key) {
                  return obj[key];
              });
          });
          rowList.unshift(colList);
      }
      // init colList
      colList = rowList.shift();
      // preserve rowid
      if (rowidList) {
          colList.unshift("rowid");
          rowList.forEach(funct...
  }
  

• Example usage:

  ...
  SELECT
      LGBM_DATASETFREE(data_test_handle),
      LGBM_DATASETFREE(data_train_handle)
  FROM __lgbm_state;
              `)
          });
          if (sqlPredictXxx === sqlPredictFile) {
              dbTableImportAsync({
                  db,
                  filename: fileActual,
                  headerMissing: true,
                  mode: "tsv",
                  tableName: "__lgbm_table_preb"
              });
          }
  ...

• 20. function debugInline(...argv)

• Description and source-code:

  function debug(...argv) {
  
  // This function will print <argv> to stderr and then return <argv>[0].
  
      __consoleError("\n\ndebugInline");
      __consoleError(...argv);
      __consoleError("\n");
      return argv[0];
  }

• Example usage:

  N/A

• 21. function fsCopyFileUnlessTest(file1, file2, mode)

• Description and source-code:

  async function fsCopyFileUnlessTest(file1, file2, mode) {
  
  // This function will copy <file1> to <file2> unless <npm_config_mode_test> = 1.
  
      if (npm_config_mode_test && mode !== "force") {
          return;
      }
      await moduleFs.promises.copyFile(file1, file2, mode | 0);
  }

• Example usage:

  ...
  jstestDescribe((
  "test_fsXxx"
  ), function test_fsXxx() {
  jstestIt((
      "test fsXxx handling-behavior"
  ), async function () {
      await Promise.all([
          fsCopyFileUnlessTest("", ""),
          fsExistsUnlessTest(""),
          fsReadFileUnlessTest("", ""),
          fsWriteFileUnlessTest("", ""),
          //
          fsCopyFileUnlessTest(
              "package.json",
              ".tmp/test_fsCopyFileUnlessTest_force",
  ...

• 22. function fsExistsUnlessTest(file, mode)

• Description and source-code:

  async function fsExistsUnlessTest(file, mode) {
  
  // This function will test if <file> exists unless <npm_config_mode_test> = 1.
  
      if (npm_config_mode_test && mode !== "force") {
          return false;
      }
      try {
          await moduleFs.promises.access(file);
          return true;
      } catch (ignore) {
          return false;
      }
  }

• Example usage:

  ...
  "test_fsXxx"
  ), function test_fsXxx() {
  jstestIt((
      "test fsXxx handling-behavior"
  ), async function () {
      await Promise.all([
          fsCopyFileUnlessTest("", ""),
          fsExistsUnlessTest(""),
          fsReadFileUnlessTest("", ""),
          fsWriteFileUnlessTest("", ""),
          //
          fsCopyFileUnlessTest(
              "package.json",
              ".tmp/test_fsCopyFileUnlessTest_force",
              "force"
  ...

• 23. function fsReadFileUnlessTest(file, mode, defaultData)

• Description and source-code:

  async function fsReadFileUnlessTest(file, mode, defaultData) {
  
  // This function will read <data> from <file> unless <npm_config_mode_test> = 1.
  
      if (npm_config_mode_test && mode !== "force") {
          return defaultData;
      }
      return await moduleFs.promises.readFile(
          file,
          mode && mode.replace("force", "utf8")
      );
  }

• Example usage:

  ...
              valActual = valActual.replace((/ /g), "\t");
              valActual = valActual.trim() + "\n";
              await fsWriteFileUnlessTest(
                  "test_data_sinefit.csv",
                  valActual,
                  String("1").replace(npm_config_mode_test_save, "force")
              );
              valExpect = await fsReadFileUnlessTest(
                  "test_data_sinefit.csv",
                  "force"
              );
              assertJsonEqual(valActual, valExpect);
          }())
      ]);
  });
  ...

• 24. function fsWriteFileUnlessTest(file, data, mode)

• Description and source-code:

  async function fsWriteFileUnlessTest(file, data, mode) {
  
  // This function will write <data> to <file> unless <npm_config_mode_test> = 1.
  
      if (npm_config_mode_test && mode !== "force") {
          return;
      }
      await moduleFs.promises.writeFile(file, data);
  }

• Example usage:

  ...
          }).join(" ");
      }).join("\n")
  );
  valActual = valActual.replace((/  /g), " null ");
  valActual = valActual.replace((/ \n/g), "\n");
  valActual = valActual.replace((/ /g), "\t");
  valActual = valActual.trim() + "\n";
  await fsWriteFileUnlessTest(
      "test_data_sinefit.csv",
      valActual,
      String("1").replace(npm_config_mode_test_save, "force")
  );
  valExpect = await fsReadFileUnlessTest(
      "test_data_sinefit.csv",
      "force"
  ...

• 25. function jsbatonGetInt64(baton, argi)

• Description and source-code:

  function jsbatonGetInt64(baton, argi) {
  
  // This function will return int64-value from <baton> at <argi>.
  
      return baton.getBigInt64(JSBATON_OFFSET_ARGV + argi * 8, true);
  }

• Example usage:

  ...
      return;
  }
  baton = await dbNoopAsync(undefined, valIn, undefined);
  baton = baton[0];
  valActual = (
      typeof valIn === "string"
      ? jsbatonGetString(baton, 1)
      : String(jsbatonGetInt64(baton, 1))
  );
  valExpect = String(valExpect);
  if (typeof valIn === "bigint") {
      valIn = String(valIn);
  }
  assertJsonEqual(valActual, valExpect, {
      ii,
  ...

• 26. function jsbatonGetString(baton, argi)

• Description and source-code:

  function jsbatonGetString(baton, argi) {
  
  // This function will return string-value from <baton> at <argi>.
  
      let offset = baton.getInt32(JSBATON_OFFSET_ARGV + argi * 8, true);
      return new TextDecoder().decode(new Uint8Array(
          baton.buffer,
          baton.byteOffset + offset + 1 + 4,
          // remove null-terminator from string
          baton.getInt32(offset + 1, true) - 1
      ));
  }

• Example usage:

  ...
      }, "invalid arg|integer");
      return;
  }
  baton = await dbNoopAsync(undefined, valIn, undefined);
  baton = baton[0];
  valActual = (
      typeof valIn === "string"
      ? jsbatonGetString(baton, 1)
      : String(jsbatonGetInt64(baton, 1))
  );
  valExpect = String(valExpect);
  if (typeof valIn === "bigint") {
      valIn = String(valIn);
  }
  assertJsonEqual(valActual, valExpect, {
  ...

• 27. function listOrEmptyList(list)

• Description and source-code:

  function listOrEmptyList(list) {
  
  // This function will return <list> or empty-list if falsy.
  
      return list || [];
  }

• Example usage:

  ...
      await assertErrorThrownAsync(function () {
          assertOrThrow(undefined, "undefined");
      }, "undefined");
      await assertErrorThrownAsync(function () {
          assertOrThrow(undefined, new Error());
      }, "");
      // test listOrEmptyList null-case handling-behavior
      assertJsonEqual(listOrEmptyList(), []);
      // test waitAsync null-case handling-behavior
      await waitAsync();
  });
  });
  
  jstestDescribe((
  "test_sqlite"
  ...

• 28. function noop(val)

• Description and source-code:

  function noop(val) {
  
  // This function will do nothing except return <val>.
  
      return val;
  }

• Example usage:

  ...
  let sql;
  let valActual;
  sql = (
      func === "SHA256"
      ? `SELECT HEX(${func}(${arg}))`
      : `SELECT ${func}(${arg})`
  );
  valActual = noop(
      await dbExecAndReturnLastValue({
          db,
          sql
      })
  );
  assertJsonEqual(valActual, valExpect, {
      sql,
  ...

• 29. function objectDeepCopyWithKeysSorted(obj)

• Description and source-code:

  function objectDeepCopyWithKeysSorted(obj) {
  
  // This function will recursively deep-copy <obj> with keys sorted.
  
      let sorted;
      if (typeof obj !== "object" || !obj) {
          return obj;
      }
  
  // Recursively deep-copy list with child-keys sorted.
  
      if (Array.isArray(obj)) {
          return obj.map(objectDeepCopyWithKeysSorted);
      }
  
  // Recursively deep-copy obj with keys sorted.
  
      sorted = Object.create(null);
      Object.keys(obj).sort().forEach(function (key) {
          sorted[key] = objectDeepCopyWithKeysSorted(obj[key]);
      });
      return sorted;
  }

• Example usage:

  ...
          return obj.map(objectDeepCopyWithKeysSorted);
      }
  
  // Recursively deep-copy obj with keys sorted.
  
      sorted = Object.create(null);
      Object.keys(obj).sort().forEach(function (key) {
          sorted[key] = objectDeepCopyWithKeysSorted(obj[key]);
      });
      return sorted;
  }
  
  async function sqlmathInit() {
  
  // This function will init sqlmath.
  ...

• 30. function sqlmathWebworkerInit({ db, modeTest })

• Description and source-code:

  function sqlmathWebworkerInit({
      db,
      modeTest
  }) {
  
  // This function will init sqlmath web-worker.
  
  // Feature-detect browser.
  
      let Worker = globalThis.Worker;
      IS_BROWSER = true;
      if (modeTest) {
          Worker = function () {
              return;
          };
      }
      sqlWorker = new Worker("sqlmath_wasm.js");
      sqlWorker.onmessage = function ({
          data
      }) {
          sqlMessageDict[data.id](data);
      };
      if (modeTest) {
          sqlWorker.postMessage = function (data) {
              setTimeout(function () {
                  sqlWorker.onmessage({data});
              });
          };
          // test dbCallAsync handling-behavior
          dbCallAsync(
              jsbatonCreate("testTimeElapsed"),
              [
                  true
              ]
          );
          // test dbFileLoadAsync handling-behavior
          dbFileLoadAsync({db, filename: "aa", modeTest});
          // test jsonParseArraybuffer handling-behavior
          jsonParseArraybuffer(new TextEncoder().encode("0"));
          // revert IS_BROWSER
          IS_BROWSER = undefined;
      }
  }

• Example usage:

  ...
  ), function test_sqlmathWebworkerInit() {
      jstestIt((
          "test sqlmathWebworkerInit handling-behavior"
      ), async function () {
          let db = await dbOpenAsync({
              dbData: new ArrayBuffer()
          });
          sqlmathWebworkerInit({
              db,
              modeTest: true
          });
      });
  });
  
  export {
  ...

• 31. function waitAsync(timeout)

• Description and source-code:

  function waitAsync(timeout) {
  
  // This function will wait <timeout> ms.
  
      return new Promise(function (resolve) {
          setTimeout(resolve, timeout * !npm_config_mode_test);
      });
  }

• Example usage:

  ...
      }, "undefined");
      await assertErrorThrownAsync(function () {
          assertOrThrow(undefined, new Error());
      }, "");
      // test listOrEmptyList null-case handling-behavior
      assertJsonEqual(listOrEmptyList(), []);
      // test waitAsync null-case handling-behavior
      await waitAsync();
  });
  });
  
  jstestDescribe((
  "test_sqlite"
  ), function test_sqlite() {
  jstestIt((
  ...

• 32. number LGBM_DTYPE_FLOAT32

• 33. number LGBM_DTYPE_FLOAT64

• 34. number LGBM_DTYPE_INT32

• 35. number LGBM_DTYPE_INT64

• 36. number LGBM_FEATURE_IMPORTANCE_GAIN

• 37. number LGBM_FEATURE_IMPORTANCE_SPLIT

• 38. number LGBM_MATRIX_TYPE_CSC

• 39. number LGBM_MATRIX_TYPE_CSR

• 40. number LGBM_PREDICT_CONTRIB

• 41. number LGBM_PREDICT_LEAF_INDEX

• 42. number LGBM_PREDICT_NORMAL

• 43. number LGBM_PREDICT_RAW_SCORE

• 44. number SQLITE_OPEN_AUTOPROXY

• 45. number SQLITE_OPEN_CREATE

• 46. number SQLITE_OPEN_DELETEONCLOSE

• 47. number SQLITE_OPEN_EXCLUSIVE

• 48. number SQLITE_OPEN_FULLMUTEX

• 49. number SQLITE_OPEN_MAIN_DB

• 50. number SQLITE_OPEN_MAIN_JOURNAL

• 51. number SQLITE_OPEN_MEMORY

• 52. number SQLITE_OPEN_NOFOLLOW

• 53. number SQLITE_OPEN_NOMUTEX

• 54. number SQLITE_OPEN_PRIVATECACHE

• 55. number SQLITE_OPEN_READONLY

• 56. number SQLITE_OPEN_READWRITE

• 57. number SQLITE_OPEN_SHAREDCACHE

• 58. number SQLITE_OPEN_SUBJOURNAL

• 59. number SQLITE_OPEN_SUPER_JOURNAL

• 60. number SQLITE_OPEN_TEMP_DB

• 61. number SQLITE_OPEN_TEMP_JOURNAL

• 62. number SQLITE_OPEN_TRANSIENT_DB

• 63. number SQLITE_OPEN_URI

• 64. number SQLITE_OPEN_WAL

• 65. object DB_EXEC_PROFILE_DICT

• 66. string SQLMATH_EXE

• 67. string SQLMATH_NODE

• 68. string version