main.go

package main

import (
	"bufio"
	"fmt"
	"os"
	"strings"
)

func main() {
	dbPath := "testdb.kv"
	
	kv := &KV{Path: dbPath}
	if err := kv.Open(); err != nil {
		fmt.Println("Failed to open KV store:", err)
		return
	}
	defer kv.Close()

	db := &DB{Path: dbPath, kv: kv}

	fmt.Println("Welcome to the GopherSQL Interactive SQL Shell!")
	fmt.Println("Type your SQL queries below. Type 'exit' or 'quit' to close.")

	scanner := bufio.NewScanner(os.Stdin)
	for {
		fmt.Print("db> ")
		if !scanner.Scan() {
			break
		}
		
		input := strings.TrimSpace(scanner.Text())
		if input == "" {
			continue
		}
		
		if strings.EqualFold(input, "exit") || strings.EqualFold(input, "quit") {
			break
		}

		tx := &DBTX{}
		db.Begin(tx)

		res, err := ExecuteQuery(tx, input)
		if err != nil {
			fmt.Println("Error:", err)
			db.Abort(tx)
			continue
		}

		if err := db.Commit(tx); err != nil {
			fmt.Println("Commit Error:", err)
			continue
		}

		if res != nil {
			// It was a SELECT query
			if results, ok := res.([]Record); ok {
				if len(results) == 0 {
					fmt.Println("(0 rows)")
				} else {
					for _, rec := range results {
						for i, val := range rec.Vals {
							if i > 0 {
								fmt.Print(" | ")
							}
							if val.Type == TYPE_INT64 {
								fmt.Printf("%s: %d", rec.Cols[i], val.I64)
							} else {
								fmt.Printf("%s: %s", rec.Cols[i], string(val.Str))
							}
						}
						fmt.Println()
					}
					fmt.Printf("(%d rows)\n", len(results))
				}
			}
		} else {
			fmt.Println("Success.")
		}
	}
}