import (
	"database/sql"
	"errors"
	"fmt"

	_ "modernc.org/sqlite"
)

func openCourseDB(path string) *sql.DB {
	db, err := sql.Open("sqlite", path)
	if err != nil {
		panic(err)
	}
	db.SetMaxOpenConns(1)
	return db
}

const flatDBPath = "file:_02_1_relational_solutions.db"

%%
db := openCourseDB(flatDBPath)
defer db.Close()

db.Exec(`DROP TABLE IF EXISTS orders_flat`)
db.Exec(`CREATE TABLE orders_flat (
	order_id INTEGER PRIMARY KEY,
	customer_id INTEGER,
	customer_name TEXT,
	customer_email TEXT,
	customer_address TEXT,
	product_name TEXT,
	price INTEGER,
	qty INTEGER
)`)

seed := []struct {
	customerID                       int
	customerName, email, address     string
	productName                      string
	price, qty                       int
}{
	{1, "佐藤", "sato@example.com", "東京都渋谷区1-1", "マグカップ", 800, 2},
	{1, "佐藤", "sato@example.com", "東京都渋谷区1-1", "ノート", 300, 1},
	{1, "佐藤", "sato@example.com", "東京都渋谷区1-1", "ペン", 150, 5},
	{2, "鈴木", "suzuki@example.com", "大阪府大阪市2-2", "マグカップ", 800, 3},
	{2, "鈴木", "suzuki@example.com", "大阪府大阪市2-2", "ノート", 300, 2},
	{3, "田中", "tanaka@example.com", "愛知県名古屋市3-3", "ペン", 150, 1},
}
for _, s := range seed {
	_, err := db.Exec(
		`INSERT INTO orders_flat (customer_id, customer_name, customer_email, customer_address, product_name, price, qty)
		 VALUES (?, ?, ?, ?, ?, ?, ?)`,
		s.customerID, s.customerName, s.email, s.address, s.productName, s.price, s.qty)
	if err != nil {
		panic(err)
	}
}
fmt.Println("✅ orders_flat をシードしました（6行、顧客3人ぶん）")

✅ orders_flat をシードしました（6行、顧客3人ぶん）

func isCandidateKey(db *sql.DB, column string) (bool, error) {
	// column は列名（SQLの識別子）なので、値のプレースホルダ(?)では埋め込めない。
	// fmt.Sprintf で組み立てるが、外部入力（ユーザーが送ってきた文字列）を
	// そのまま渡してはいけない（SQLインジェクションになる）。このノートブックでは
	// 常に固定の既知の列名だけを渡す前提。
	query := fmt.Sprintf(`SELECT COUNT(*), COUNT(DISTINCT %s) FROM orders_flat`, column)
	var total, distinct int
	if err := db.QueryRow(query).Scan(&total, &distinct); err != nil {
		return false, err
	}
	return total == distinct, nil
}

import "reflect"

func mustEqual(got, want any, name string) {
	if reflect.DeepEqual(got, want) {
		fmt.Printf("✅ Passed: %s\n", name)
		return
	}
	panic(fmt.Sprintf("❌ %s\n  got  = %v (%T)\n  want = %v (%T)", name, got, got, want, want))
}

%%
// このチェックは SELECT のみで DB を変更しないため、何度実行しても同じ結果になる。
db := openCourseDB(flatDBPath)
defer db.Close()

ok1, err1 := isCandidateKey(db, "order_id")
mustEqual(err1, nil, "order_id はエラーなし")
mustEqual(ok1, true, "order_id は候補キーの条件を満たす（重複なし）")

ok2, err2 := isCandidateKey(db, "customer_id")
mustEqual(err2, nil, "customer_id はエラーなし")
mustEqual(ok2, false, "customer_id は候補キーではない（重複あり）")

ok3, err3 := isCandidateKey(db, "customer_email")
mustEqual(err3, nil, "customer_email はエラーなし")
mustEqual(ok3, false, "customer_email も候補キーではない（重複あり）")

fmt.Println("🎉 すべてのチェックが通りました")

✅ Passed: order_id はエラーなし
✅ Passed: order_id は候補キーの条件を満たす（重複なし）

✅ Passed: customer_id はエラーなし
✅ Passed: customer_id は候補キーではない（重複あり）
✅ Passed: customer_email はエラーなし
✅ Passed: customer_email も候補キーではない（重複あり）
🎉 すべてのチェックが通りました

解答 02.1 — リレーショナルモデル（isCandidateKey）¶

前提コード（問題ノートブックと同じ定義・シード）¶

解答: isCandidateKey¶

チェック（問題ノートブックと同じ期待値）¶

解説¶