3971101424

Build Type

push

github

Committed by Christopher Caldwell

Commit Message

update linux tile

Run Details

3572 of 8035 branches covered (44.46%)

Branch coverage included in aggregate %.

15055 of 20471 relevant lines covered (73.54%)

1437.27 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

61.83

/lib/db/sqlUtils.ts

/**
 * Core SQL Utility methods
 */
import { StringUtils } from './stringUtils';
import { UserColumn } from '../user/userColumn';
import { UserTable } from '../user/userTable';
import { TableMapping } from './tableMapping';
import { TableInfo } from './table/tableInfo';
import { SQLiteMaster } from './master/sqliteMaster';
import { SQLiteMasterQuery } from './master/sqliteMasterQuery';
import { SQLiteMasterColumn } from './master/sqliteMasterColumn';
import { GeoPackageDataType } from './geoPackageDataType';
import { ResultSet } from './resultSet';
import { ResultSetResult } from './resultSetResult';
import { ResultUtils } from './resultUtils';
import { ContentValues } from '../user/contentValues';
import { DBAdapter } from './dbAdapter';
import type { GeoPackageConnection } from './geoPackageConnection';
import { DBValue } from './dbValue';

export class SQLUtils {
  /**
   * Pattern for matching numbers
   */
  static NUMBER_PATTERN = '\\d+';

  static quoteWrap(str: string): string {
    return StringUtils.quoteWrap(str);
  }

  /**
   * Create the user defined table SQL
   *
   * @param table user table
   * @param <TColumn> column type
   * @return create table SQL
   */
  static createTableSQL(table: UserTable<UserColumn>): string {
    // Build the create table sql
    let sql = '';
    sql = sql
      .concat('CREATE TABLE ')
      .concat(StringUtils.quoteWrap(table.getTableName()))
      .concat(' (');

    // Add each column to the sql
    const columns = table.getUserColumns().getColumns();
    for (let i = 0; i < columns.length; i++) {
      const column = columns[i];
      if (i > 0) {
        sql = sql.concat(',');
      }
      sql = sql.concat('\n  ');
      sql = sql.concat(SQLUtils.columnSQL(column));
    }

    // Add unique constraints
    table
      .getConstraints()
      .all()
      .forEach(constraint => {
        sql = sql.concat(',\n  ');
        sql = sql.concat(constraint.buildSql());
      });

    sql = sql.concat('\n);');
    return sql;
  }

  /**
   * Create the column SQL in the format:
   * "column_name" column_type[(max)] [NOT NULL] [PRIMARY KEY AUTOINCREMENT]
   * @param column user column
   * @return column SQL
   */
  static columnSQL(column: UserColumn): string {
    return StringUtils.quoteWrap(column.getName()) + ' ' + SQLUtils.columnDefinition(column);
  }

  /**
   * Create the column definition SQL in the format:
   * column_type[(max)] [NOT NULL] [PRIMARY KEY AUTOINCREMENT]
   * @param column  user column
   * @return column definition SQL
   */
  static columnDefinition(column: UserColumn): string {
    let sql = '';

    sql = sql.concat(column.getType());
    if (column.hasMax()) {
      sql = sql
        .concat('(')
        .concat(column.getMax().toString())
        .concat(')');
    }

    column
      .getConstraints()
      .all()
      .forEach(constraint => {
        sql = sql.concat(' ');
        sql = sql.concat(column.buildConstraintSql(constraint));
      });

    return sql.toString();
  }

  /**
   * Query for the foreign keys value
   *
   * @param db
   *            connection
   * @return true if enabled, false if disabled
   */
  static foreignKeys(db: GeoPackageConnection): boolean {
    const foreignKeys = db.get('PRAGMA foreign_keys', null)[0] as boolean;
    return foreignKeys !== null && foreignKeys !== undefined && foreignKeys;
  }

  /**
   * Change the foreign keys state
   * @param db connection
   * @param on true to turn on, false to turn off
   * @return previous foreign keys value
   */
  static setForeignKeys(db: GeoPackageConnection, on: boolean): boolean {
    const foreignKeys = SQLUtils.foreignKeys(db);
    if (foreignKeys !== on) {
      const sql = SQLUtils.foreignKeysSQL(on);
      db.run(sql);
    }
    return foreignKeys;
  }

  /**
   * Create the foreign keys SQL
   * @param on true to turn on, false to turn off
   * @return foreign keys SQL
   */
  static foreignKeysSQL(on: boolean): string {
    return 'PRAGMA foreign_keys = ' + on;
  }

  /**
   * Perform a foreign key check
   * @param db connection
   * @return empty list if valid or violation errors, 4 column values for each violation. see SQLite PRAGMA foreign_key_check
   */
  static foreignKeyCheck(db: GeoPackageConnection): any[] {
    const sql = SQLUtils.foreignKeyCheckSQL(null);
    return db.all(sql, null);
  }

  /**
   * Perform a foreign key check
   * @param db connection
   * @param tableName table name
   * @return empty list if valid or violation errors, 4 column values for each violation. see SQLite PRAGMA foreign_key_check
   */
  static foreignKeyCheckForTable(db: GeoPackageConnection, tableName: string): any[] {
    const sql = SQLUtils.foreignKeyCheckSQL(tableName);
    return db.all(sql, null);
  }

  /**
   * Create the foreign key check SQL
   * @param tableName table name
   * @return foreign key check SQL
   */
  static foreignKeyCheckSQL(tableName: string): string {
    return (
      'PRAGMA foreign_key_check' +
      (tableName !== null && tableName !== undefined ? '(' + StringUtils.quoteWrap(tableName) + ')' : '')
    );
  }

  /**
   * Create the integrity check SQL
   * @return integrity check SQL
   */
  static integrityCheckSQL(): string {
    return 'PRAGMA integrity_check';
  }

  /**
   * Create the quick check SQL
   * @return quick check SQL
   */
  static quickCheckSQL(): string {
    return 'PRAGMA quick_check';
  }

  /**
   * Drop the table if it exists
   * @param db connection
   * @param tableName table name
   */
  static dropTable(db: GeoPackageConnection, tableName: string): void {
    const sql = SQLUtils.dropTableSQL(tableName);
    db.run(sql);
  }

  /**
   * Create the drop table if exists SQL
   * @param tableName table name
   * @return drop table SQL
   */
  static dropTableSQL(tableName: string): string {
    return 'DROP TABLE IF EXISTS ' + StringUtils.quoteWrap(tableName);
  }

  /**
   * Drop the view if it exists
   * @param db connection
   * @param viewName view name
   */
  static dropView(db: GeoPackageConnection, viewName: string): void {
    const sql = SQLUtils.dropViewSQL(viewName);
    db.run(sql);
  }

  /**
   * Create the drop view if exists SQL
   * @param viewName view name
   * @return drop view SQL
   */
  static dropViewSQL(viewName: string): string {
    return 'DROP VIEW IF EXISTS ' + StringUtils.quoteWrap(viewName);
  }

  /**
   * Transfer table content from one table to another
   * @param db connection
   * @param tableMapping table mapping
   */
  static transferTableContentForTableMapping(db: GeoPackageConnection, tableMapping: TableMapping): void {
    const sql = SQLUtils.transferTableContentSQL(tableMapping);
    db.run(sql);
  }

  /**
   * Create insert SQL to transfer table content from one table to another
   * @param tableMapping table mapping
   * @return transfer SQL
   */
  static transferTableContentSQL(tableMapping: TableMapping): string {
    let insert = 'INSERT INTO ';
    insert = insert.concat(StringUtils.quoteWrap(tableMapping.toTable));
    insert = insert.concat(' (');
    let selectColumns = '';
    let where = '';
    if (tableMapping.hasWhere()) {
      where = where.concat(tableMapping.where);
    }
    const columns = tableMapping.getColumns();
    tableMapping.getColumnNames().forEach((key: string) => {
      const toColumn = key;
      const column = columns[key];
      if (selectColumns.length > 0) {
        insert = insert.concat(', ');
        selectColumns = selectColumns.concat(', ');
      }
      insert = insert.concat(StringUtils.quoteWrap(toColumn));

      if (column.hasConstantValue()) {
        selectColumns = selectColumns.concat(column.getConstantValueAsString());
      } else {
        if (column.hasDefaultValue()) {
          selectColumns = selectColumns.concat('ifnull(');
        }
        selectColumns = selectColumns.concat(StringUtils.quoteWrap(column.fromColumn));
        if (column.hasDefaultValue()) {
          selectColumns = selectColumns.concat(',');
          selectColumns = selectColumns.concat(column.getDefaultValueAsString());
          selectColumns = selectColumns.concat(')');
        }
      }

      if (column.hasWhereValue()) {
        if (where.length > 0) {
          where = where.concat(' AND ');
        }
        where = where.concat(StringUtils.quoteWrap(column.fromColumn));
        where = where.concat(' ');
        where = where.concat(column.whereOperator);
        where = where.concat(' ');
        where = where.concat(column.getWhereValueAsString());
      }
    });

    insert = insert.concat(') SELECT ');
    insert = insert.concat(selectColumns);
    insert = insert.concat(' FROM ');
    insert = insert.concat(StringUtils.quoteWrap(tableMapping.fromTable));

    if (where.length > 0) {
      insert = insert.concat(' WHERE ');
      insert = insert.concat(where);
    }

    return insert.toString();
  }

  /**
   * Transfer table content to itself with new rows containing a new column
   * value. All rows containing the current column value are inserted as new
   * rows with the new column value.
   * @param db connection
   * @param tableName table name
   * @param columnName column name
   * @param newColumnValue new column value for new rows
   * @param currentColumnValue column value for rows to insert as new rows
   * @param idColumnName id column name
   */
  static transferTableContent(
    db: GeoPackageConnection,
    tableName: string,
    columnName: string,
    newColumnValue: any,
    currentColumnValue: any,
    idColumnName?: string,
  ): void {
    const tableInfo = TableInfo.info(db, tableName);
    const tableMapping = TableMapping.fromTableInfo(tableInfo);
    if (idColumnName != null) {
      tableMapping.removeColumn(idColumnName);
    }
    const column = tableMapping.getColumn(columnName);
    column.constantValue = newColumnValue;
    column.whereValue = currentColumnValue;
    SQLUtils.transferTableContentForTableMapping(db, tableMapping);
  }

  /**
   * Get an available temporary table name. Starts with prefix_baseName and
   * then continues with prefix#_baseName starting at 1 and increasing.
   * @param db connection
   * @param prefix name prefix
   * @param baseName base name
   * @return unused table name
   */
  static tempTableName(db: GeoPackageConnection, prefix: string, baseName: string): string {
    let name = prefix + '_' + baseName;
    let nameNumber = 0;
    while (db.tableExists(name)) {
      name = prefix + ++nameNumber + '_' + baseName;
    }
    return name;
  }

  /**
   * Modify the SQL with a name change and the table mapping modifications
   * @param db optional connection, used for SQLite Master name conflict detection
   * @param name statement name
   * @param sql SQL statement
   * @param tableMapping table mapping
   * @return updated SQL, null if SQL contains a deleted column
   */
  static modifySQL(db: GeoPackageConnection, name: string, sql: string, tableMapping: TableMapping): string {
    let updatedSql = sql;
    if (name !== null && name !== undefined && tableMapping.isNewTable()) {
      const newName = SQLUtils.createName(db, name, tableMapping.fromTable, tableMapping.toTable);
      const updatedName = SQLUtils.replaceName(updatedSql, name, newName);
      if (updatedName !== null && updatedName !== undefined) {
        updatedSql = updatedName;
      }
      const updatedTable = SQLUtils.replaceName(updatedSql, tableMapping.fromTable, tableMapping.toTable);
      if (updatedTable !== null && updatedTable !== undefined) {
        updatedSql = updatedTable;
      }
    }
    updatedSql = SQLUtils.modifySQLWithTableMapping(updatedSql, tableMapping);
    return updatedSql;
  }

  /**
   * Modify the SQL with table mapping modifications
   * @param sql SQL statement
   * @param tableMapping table mapping
   * @return updated SQL, null if SQL contains a deleted column
   */
  static modifySQLWithTableMapping(sql: string, tableMapping: TableMapping): string {
    let updatedSql = sql;

    const droppedColumns = Array.from(tableMapping.droppedColumns);
    for (let i = 0; i < droppedColumns.length; i++) {
      const column = droppedColumns[i];
      const updated = SQLUtils.replaceName(updatedSql, column, ' ');
      if (updated !== null && updated !== undefined) {
        updatedSql = null;
        break;
      }
    }

    if (updatedSql !== null && updatedSql !== undefined) {
      tableMapping.getMappedColumns().forEach(column => {
        if (column.hasNewName()) {
          const updated = SQLUtils.replaceName(updatedSql, column.fromColumn, column.toColumn);
          if (updated !== null && updated !== undefined) {
            updatedSql = updated;
          }
        }
      });
    }
    return updatedSql;
  }

  /**
   * Replace the name (table, column, etc) in the SQL with the replacement.
   * The name must be surrounded by non word characters (i.e. not a subset of
   * another name).
   * @param sql SQL statement
   * @param name name
   * @param replacement replacement value
   * @return null if not modified, SQL value if replaced at least once
   */
  static replaceName(sql: string, name: string, replacement: string): string {
    let updatedSql = null;

    // Quick check if contained in the SQL
    if (sql.indexOf(name) >= 0) {
      let updated = false;
      let updatedSqlBuilder = '';

      // Split the SQL apart by the name
      const parts = sql.split(name);

      for (let i = 0; i <= parts.length; i++) {
        if (i > 0) {
          // Find the character before the name
          let before = '_';
          const beforePart = parts[i - 1];
          if (beforePart.length === 0) {
            if (i == 1) {
              // SQL starts with the name, allow
              before = ' ';
            }
          } else {
            before = beforePart.substring(beforePart.length - 1);
          }

          // Find the character after the name
          let after = '_';
          if (i < parts.length) {
            const afterPart = parts[i];
            if (afterPart.length !== 0) {
              after = afterPart.substring(0, 1);
            }
          } else if (sql.endsWith(name)) {
            // SQL ends with the name, allow
            after = ' ';
          } else {
            break;
          }

          // Check the before and after characters for non word
          // characters
          if (before.match('\\W').length > 0 && after.match('\\W').length > 0) {
            // Replace the name
            updatedSqlBuilder = updatedSqlBuilder.concat(replacement);
            updated = true;
          } else {
            // Preserve the name
            updatedSqlBuilder = updatedSqlBuilder.concat(name);
          }
        }

        // Add the part to the SQL
        if (i < parts.length) {
          updatedSqlBuilder = updatedSqlBuilder.concat(parts[i]);
        }
      }
      // Set if the SQL was modified
      if (updated) {
        updatedSql = updatedSqlBuilder.toString();
      }
    }
    return updatedSql;
  }

  /**
   * Create a new name by replacing a case insensitive value with a new value.
   * If no replacement is done, create a new name in the form name_#, where #
   * is either 2 or one greater than an existing name number suffix. When a db
   * connection is provided, check for conflicting SQLite Master names and
   * increment # until an available name is found.
   * @param db optional connection, used for SQLite Master name conflict detection
   * @param name current name
   * @param replace value to replace
   * @param replacement replacement value
   * @return new name
   */
  static createName(db: GeoPackageConnection, name: string, replace: string, replacement: string): string {
    // Attempt the replacement
    let newName = name.replace(new RegExp(replace), replacement);

    // If no name change was made
    if (newName === name) {
      let baseName = newName;
      let count = 1;
      // Find any existing end number: name_#
      const index = baseName.lastIndexOf('_');
      if (index >= 0 && index + 1 < baseName.length) {
        const numberPart = baseName.substring(index + 1);
        if (numberPart.match(SQLUtils.NUMBER_PATTERN).length > 0) {
          baseName = baseName.substring(0, index);
          count = parseInt(numberPart);
        }
      }
      // Set the new name to name_2 or name_(#+1)
      newName = baseName + '_' + ++count;

      if (db !== null && db !== undefined) {
        // Check for conflicting SQLite Master table names
        while (
          SQLiteMaster.count(db, null, SQLiteMasterQuery.createForColumnValue(SQLiteMasterColumn.NAME, newName)) > 0
        ) {
          newName = baseName + '_' + ++count;
        }
      }
    }
    return newName;
  }

  /**
   * Get the column default value as a string
   *
   * @param defaultValue default value
   * @param dataType data type
   * @return default value
   */
  public static columnDefaultValue(defaultValue: any, dataType: GeoPackageDataType): string {
    return GeoPackageDataType.columnDefaultValue(defaultValue, dataType);
  }

  /**
   * Rebuild the GeoPackage, repacking it into a minimal amount of disk space
   * @param db connection
   */
  static vacuum(db: GeoPackageConnection): void {
    db.run('VACUUM');
  }

  /**
   * Execute the SQL
   *
   * @param connection
   *            connection
   * @param sql
   *            sql statement
   */
  public static execSQL(connection: GeoPackageConnection, sql: string): void {
    connection.connectionSource.run(sql);
  }

  /**
   * Query for results
   * @param connection connection
   * @param sql sql statement
   * @param selectionArgs selection arguments
   * @return result set
   */
  public static query(connection: GeoPackageConnection | DBAdapter, sql: string, selectionArgs: [] | Record<string, any>): ResultSet {
    return connection.query(sql, selectionArgs);
  }

  /**
   * Query for values up to the limit
   *
   * @param connection connection
   * @param sql sql statement
   * @param args arguments
   * @param limit result row limit
   * @return results
   */
  public static queryResults(connection: GeoPackageConnection | DBAdapter, sql: string, args: [] | Record<string, any>, limit: number): Array<Array<any>> {
    const result = SQLUtils.wrapQuery(connection, sql, args);
    const value = ResultUtils.buildResults(result, limit);
    result.close();
    return value;
  }

  /**
   * Count for query
   * @param connection connection
   * @param tableName table
   * @param where where clause
   * @param whereArgs where arguments
   * @return number the count of rows
   */
  public static count(connection: GeoPackageConnection, tableName: string, where: string, whereArgs: [] | Record<string, any>): number {
    return connection.connectionSource.count(tableName, where, whereArgs);
  }

  /**
   * Attempt to count the results of the query
   * @param connection connection
   * @param sql SQL statement
   * @param selectionArgs selection arguments
   * @return count if known, -1 if not able to determine
   */
  public static countSqlQuery(connection: GeoPackageConnection | DBAdapter, sql: string, selectionArgs: any[]): number {
    let sqlCommands = [];

    const upperCaseSQL = sql.toUpperCase();
    let afterSelectIndex = upperCaseSQL.indexOf("SELECT") + "SELECT".length;
    let upperCaseAfterSelect = upperCaseSQL.substring(afterSelectIndex).trim();

    if (upperCaseAfterSelect.startsWith("COUNT")) {
      sqlCommands.push(sql);
    } else {

      let fromIndex = upperCaseSQL.indexOf("FROM");
      if (upperCaseAfterSelect.startsWith("DISTINCT")) {

        let commaIndex = upperCaseSQL.indexOf(",");
        if (commaIndex < 0 || commaIndex >= fromIndex) {

          sqlCommands.push(SQLUtils.adjustCount("SELECT COUNT("
            + sql.substring(afterSelectIndex, fromIndex) + ") "
            + sql.substring(fromIndex)));

          const isNull = ["SELECT COUNT(*) > 0 "];
          const columnIsNull = sql.substring(upperCaseSQL.indexOf("DISTINCT") + "DISTINCT".length, fromIndex) + "IS NULL";
          const whereIndex = upperCaseSQL.indexOf("WHERE");
          let endIndex = sql.indexOf(";");
          if (endIndex < 0) {
            endIndex = sql.length;
          }
          if (whereIndex >= 0) {
            isNull.push(sql.substring(fromIndex, whereIndex + "WHERE".length));
            isNull.push(columnIsNull);
            isNull.push(" AND ( ");
            isNull.push(sql.substring(whereIndex + "WHERE".length, endIndex));
            isNull.push(" )");
          } else {
            isNull.push(sql.substring(fromIndex, endIndex));
            isNull.push(" WHERE");
            isNull.push(columnIsNull);
          }
          sqlCommands.push(SQLUtils.adjustCount(isNull.join('')));
        }

      } else if (fromIndex != -1) {
        sqlCommands.push(SQLUtils.adjustCount("SELECT COUNT(*) " + sql.substring(fromIndex)));
      }
    }

    let count = -1;
    if (sqlCommands.length === 0) {
      // Unable to count
      console.info("Unable to count query without result iteration. SQL: " + sql + ", args: " + selectionArgs);
    } else {
      count = 0;
      for (const sqlCommand of sqlCommands) {
        try {
          const value = SQLUtils.querySingleResultWithColumnIndex(connection, sqlCommand, selectionArgs, 0);
          if (value != null) {
            count += value as number;
          }
        } catch (e) {
          console.warn("Unable to count query without result iteration. SQL: " + sql + ", args: " + selectionArgs);
          count = -1;
        }
      }
    }
    return count;
  }

  /**
   * Adjust the count statement as needed
   * @param sql sql statement
   * @return adjusted or original statement
   */
  private static adjustCount(sql: string): string {
    const upperCase = sql.toUpperCase();
    let limitIndex = upperCase.indexOf(" LIMIT ");
    if (limitIndex >= 0) {
      let lastParenthesis = sql.lastIndexOf(')');
      if (lastParenthesis == -1 || limitIndex > lastParenthesis) {
        sql = sql.substring(0, limitIndex);
      }
    }
    return sql;
  }

  // /**
  //  * Create SQL for adding a column
  //  * @param db connection
  //  * @param tableName table name
  //  * @param column user column
  //  */
  // public static addColumn(db: GeoPackageConnection, tableName: string, column: UserColumn): void {
  //   AlterTable.addColumn(db, tableName, column.getName(), SQLUtils.columnDefinition(column));
  // }

  /**
   * Perform the query and wrap as a result
   * @param connection connection
   * @param sql sql statement
   * @param selectionArgs selection arguments
   * @return result
   */
  public static wrapQuery(connection: GeoPackageConnection | DBAdapter, sql: string, selectionArgs: [] | Record<string, any>): ResultSetResult {
    return new ResultSetResult(this.query(connection, sql, selectionArgs));
  }

  /**
   * Query the SQL for a single result object with the expected data type
   * @param connection connection
   * @param sql sql statement
   * @param args arguments
   * @param columnName column name
   * @return result, null if no result
   */
  public static querySingleResult(connection: GeoPackageConnection, sql: string, args: [] | Record<string, any>, columnName: string): any {
    const result = SQLUtils.wrapQuery(connection, sql, args);
    const value =  ResultUtils.buildSingleResult(result, columnName);
    result.close();
    return value;
  }

  /**
   * Query the SQL for a single result object with the expected data type
   * @param connection connection
   * @param sql sql statement
   * @param args arguments
   * @param columnIdx column index
   * @return result, null if no result
   */
  public static querySingleResultWithColumnIndex(connection: GeoPackageConnection | DBAdapter, sql: string, args: [] | Record<string, any>, columnIdx: number = 0): any {
    const result = SQLUtils.wrapQuery(connection, sql, args);
    const value = ResultUtils.buildSingleResultWithColumnIndex(result, columnIdx);
    result.close();
    return value;
  }

  /**
   * Execute a deletion
   * @param connection connection
   * @param table table name
   * @param where where clause
   * @param args where arguments
   * @return deleted count
   */
  public static delete(connection: GeoPackageConnection, table: string, where: string, args: []): number {
    return connection.delete(table, where, args);
  }

  /**
   * Update table rows
   * @param connection connection
   * @param table table name
   * @param values content values
   * @param whereClause where clause
   * @param whereArgs where arguments
   * @return updated count
   */
  public static update(connection: GeoPackageConnection, table: string, values: ContentValues, whereClause: string, whereArgs: DBValue[]): number {
    const update = [];
    update.push("update ");
    update.push(SQLUtils.quoteWrap(table));
    update.push(" set ");
    const setValuesSize = values.size();
    const argsSize = (whereArgs == null) ? setValuesSize : (setValuesSize + whereArgs.length);
    const args = [];
    let i = 0;
    for (const colName of values.keySet()) {
      update.push((i > 0) ? "," : "");
      update.push(SQLUtils.quoteWrap(colName));
      args.push(values.get(colName));
      update.push(" = ?");
      i++;
    }
    if (whereArgs != null) {
      for (i = setValuesSize; i < argsSize; i++) {
        args[i] = whereArgs[i - setValuesSize];
      }
    }
    if (whereClause != null) {
      update.push(" WHERE ");
      update.push(whereClause);
    }
    const sql = update.join('');
    return connection.run(sql, args).changes;
  }

  /**
   * Insert a new row
   *
   * @param connection connection
   * @param table table name
   * @param values content values
   * @return row id or -1 on an exception
   */
  public static insert(connection: GeoPackageConnection, table: string, values: ContentValues): number {
    try {
      return this.insertOrThrow(connection, table, values);
    } catch (e) {
      console.error(e);
      console.warn("Error inserting into table: " + table + ", Values: " + values);
      return -1;
    }
  }

  /**
   * Insert a new row
   * @param connection connection
   * @param table table name
   * @param values content values
   * @return row id
   */
  public static insertOrThrow(connection: GeoPackageConnection, table: string, values: ContentValues): number {
    const insert = [];
    insert.push('insert into ');
    insert.push(SQLUtils.quoteWrap(table));
    insert.push(' (');
    let args = [];
    let size = (values != null && values.size() > 0) ? values.size() : 0;
    let i = 0;
    for (const colName of values.keySet()) {
      insert.push((i > 0) ? "," : "");
      insert.push(SQLUtils.quoteWrap(colName));
      args.push(values.get(colName));
      i++;
    }
    insert.push(')');
    insert.push(" values (");
    for (i = 0; i < size; i++) {
      insert.push((i > 0) ? ",?" : "?");
    }
    insert.push(')');
    const sql = insert.join('');
    return connection.insert(sql, args);
  }
}

ngageoint / geopackage-js / 3971101424

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous