import csv from 'csv-parser'; import fs from 'fs'; import sqlite3 from 'sqlite3'; export default function handler(req,res) { const DB_NAME = 'data/appUser.db'; const TABLE_NAME = 'user'; // Open a connection to the SQLite database const db = new sqlite3.Database(DB_NAME); const query = `SELECT * FROM ${TABLE_NAME}`; function getAllRows(tableName) { return new Promise((resolve, reject) => { const sql = `SELECT * FROM ${tableName} WHERE id = ?`; db.all(sql, [req.query.user], (err, rows) => { if (err) { reject(err); return; } const data = rows; resolve(data); }); }); }; async function doSomething() { try { const returnData = await getAllRows('user'); res.setHeader('Content-Type', 'application/json') res.status(200).json(returnData) // console.log(data); } catch (err) { console.error(err); } } doSomething(); // const returnData = getAllRows('user'); // console.log(getAllRows('user')); // const returnData= db.run('SELECT * FROM user'); // fs.createReadStream('data/user.csv') // .pipe(csv()) // .on('data', (data) => { // const values = Object.values(data); // const placeholders = values.map(() => '?').join(','); // const sql = `INSERT INTO ${TABLE_NAME} (${Object.keys(data).join(',')}) VALUES (${placeholders})`; // db.run(sql, values, (err) => { // if (err) { // console.error(err); // } // }); // }) // .on('end', () => { // console.log(`Data inserted successfully into table ${TABLE_NAME}`); // // Close the database connection // db.close(); // }); }