package main

import (
	"context"
	"fmt"
	"log"
	"os"

	csvimporter "catalogue.midpdsa.com/modules/csv"
	"catalogue.midpdsa.com/src/db/catalogue"
	"github.com/jackc/pgx/v5"
)

func main() {
	ctx := context.Background()
	connStr := os.Getenv("MIP_DB")
	if connStr == "" {
		connStr = "postgres://user:password@localhost:5432/mydatabase?sslmode=disable"
	}

	conn, err := pgx.Connect(ctx, connStr)
	if err != nil {
		log.Fatalf("Unable to connect to database: %v\n", err)
	}
	defer conn.Close(ctx)

	queries := catalogue.New(conn)
	importer := csvimporter.NewImporter(queries)

	result, err := importer.ImportBrembo("/app/docs/database/csv/brembo_newparts.csv")
	if err != nil {
		log.Fatalf("Import failed: %v\n", err)
	}
	fmt.Printf("Import completed: table=%s inserted=%d errors=%d\n", result.Table, result.Inserted, result.Errors)
}