async query(sqlBody: string, params: any[] = [], method: 'all' | 'first' | 'run' | 'values' | 'get' = 'all') {
console.log('Query method:', method, 'SQL:', sqlBody);
try {
const cursor = this.sql.exec(sqlBody, ...params);
let rows: any[];
if (method === 'first' || method === 'get') {
const row = cursor.one();
rows = row ? [row] : [];
} else {
rows = cursor.toArray();
}
console.log('Query result rows:', rows);
// Debug each row's field values
rows.forEach((row, index) => {
console.log(`Row ${index}:`, row);
Object.entries(row).forEach(([key, value]) => {
console.log(` ${key}: ${value} (type: ${typeof value})`);
});
});
return rows;
} catch (error) {
console.error('Query error:', error);
throw error;
}
async query(sqlBody: string, params: any[] = [], method: 'all' | 'first' | 'run' | 'values' | 'get' = 'all') {
console.log('Query method:', method, 'SQL:', sqlBody);
try {
const cursor = this.sql.exec(sqlBody, ...params);
let rows: any[];
if (method === 'first' || method === 'get') {
const row = cursor.one();
rows = row ? [row] : [];
} else {
rows = cursor.toArray();
}
console.log('Query result rows:', rows);
// Debug each row's field values
rows.forEach((row, index) => {
console.log(`Row ${index}:`, row);
Object.entries(row).forEach(([key, value]) => {
console.log(` ${key}: ${value} (type: ${typeof value})`);
});
});
return rows;
} catch (error) {
console.error('Query error:', error);
throw error;
}