fixed postgres-client

This commit is contained in:
Boki 2025-06-19 21:11:50 -04:00
parent 42bc2966df
commit 4aa8b7a42d
4 changed files with 3 additions and 6 deletions

View file

@ -224,7 +224,7 @@ export class PostgreSQLClient {
} }
const { chunkSize = 1000, excludeColumns = [] } = options; const { chunkSize = 1000, excludeColumns = [] } = options;
const columns = Object.keys(data[0]).filter(col => !excludeColumns.includes(col)); const columns = Object.keys(data[0] ?? {}).filter(col => !excludeColumns.includes(col));
const updateColumns = columns.filter(col => col !== conflictColumn); const updateColumns = columns.filter(col => col !== conflictColumn);
let totalInserted = 0; let totalInserted = 0;

View file

@ -1,4 +1,3 @@
import { PoolClient } from 'pg';
import { getLogger } from '@stock-bot/logger'; import { getLogger } from '@stock-bot/logger';
import type { PostgreSQLClient } from './client'; import type { PostgreSQLClient } from './client';
import type { TransactionCallback } from './types'; import type { TransactionCallback } from './types';

View file

@ -1,4 +1,4 @@
import type { QueryResult as PgQueryResult, Pool, PoolClient, QueryResultRow } from 'pg'; import type { QueryResult as PgQueryResult, PoolClient, QueryResultRow } from 'pg';
/** /**
* PostgreSQL Client Configuration * PostgreSQL Client Configuration

View file

@ -5,8 +5,6 @@ import { QuestDBInfluxWriter } from './influx-writer';
import { QuestDBQueryBuilder } from './query-builder'; import { QuestDBQueryBuilder } from './query-builder';
import { QuestDBSchemaManager } from './schema'; import { QuestDBSchemaManager } from './schema';
import type { import type {
BaseTimeSeriesData,
InsertResult,
QueryResult, QueryResult,
QuestDBClientConfig, QuestDBClientConfig,
QuestDBConnectionOptions, QuestDBConnectionOptions,
@ -226,7 +224,7 @@ export class QuestDBClient {
table: TableNames, table: TableNames,
columns: string[], columns: string[],
interval: string, interval: string,
timeColumn: string = 'timestamp', _timeColumn: string = 'timestamp',
where?: string, where?: string,
params?: any[] params?: any[]
): Promise<QueryResult<T>> { ): Promise<QueryResult<T>> {