nextJS – קורס fullstack – כתיבה בצד שרת – route handler

const sqlite3 = require("sqlite3").verbose();

// create a new database
const db = new sqlite3.Database("mydb.db");

// define a schema for the users table
db.run(`
  CREATE TABLE IF NOT EXISTS users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    name TEXT NOT NULL,
    email TEXT NOT NULL UNIQUE,
    password TEXT NOT NULL
  )
`);

// SQL command for insertion
const createUserSQL = `INSERT INTO users (name, email, password) VALUES ('yair3', '[email protected]', '1234')`;

// Execute insert commands for each value
db.run(createUserSQL, (data, err) => {
    console.log(data);
    if (err) {
        return console.error(err.message);
    }
});

db.all("SELECT * FROM users", (err, rows) => {
    if (err) {
        return console.error(err.message);
    }
    console.log(rows);
});

// Import the necessary modules for SQLite
import sqlite3 from "sqlite3";
import { open } from "sqlite";
import { NextRequest, NextResponse } from "next/server";

// Initialize a variable to hold the SQLite database connection
let db: any = null;

export async function GET(req: NextRequest, res: NextResponse) {
    // Open a new connection if there is none
    if (!db) {
        db = await open({
            filename: "./mydb.db",
            driver: sqlite3.Database,
        });
    }

    // Query to get all users from the "user" table
    const allUsers = await db.all("SELECT * FROM u1sers");

    // Return the todos as a JSON response with a 200 status code
    return new Response(JSON.stringify(allUsers), {
        headers: { "content-type": "application/json" },
        status: 200,
    });
}

export async function POST(req: NextRequest, res: NextResponse) {
    if (!db) {
        db = await open({
            filename: "./mydb.db",
            driver: sqlite3.Database,
        });
    }

    const createUserSQL = `INSERT INTO users (name, email, password) VALUES ('yair18', '[email protected]', '1234')`;

    // Execute insert commands for each value
    const user = db.run(createUserSQL, (err: Error | null) => {
        if (err) {
            return new Response(JSON.stringify({ message: err.message }), {
                status: 500,
            });
        }
    });

    const userData = await user;
    return Response.json({ id: userData.lastID, status: 200 });
}

import { NextResponse } from "next/server";
import sqlite3 from "sqlite3";
import { open } from "sqlite";

let db: any = null;

export async function GET(
    request: Request,
    { params }: { params: { userId: string } }
) {
    const { userId } = params;

    if (!db) {
        db = await open({
            filename: "./mydb.db",
            driver: sqlite3.Database,
        });
    }

    const user = await db.get("SELECT * FROM users WHERE id = ?", userId);

    return NextResponse.json(
        {
            user,
        },
        { status: 201 }
    );
}