package db

import (
	"file-manage-ui/data"
	_ "github.com/glebarez/sqlite"
	"log"
	"xorm.io/xorm"
)

var DB *xorm.Engine

func init() {
	Open()
}
func Open() {
	db, err := xorm.NewEngine("sqlite", "./file/email.db")
	if err != nil {
		log.Fatal(err)
	}
	//创建表
	err = db.Sync2(new(data.KVStore)) //new(entity.Email), new(entity.User), new(entity.FromEmail), new(entity.Code)
	if err != nil {
		log.Fatalf("同步表结构时出错: %s", err)
	}
	DB = db
	DB.ShowSQL(true)
	DB.Logger().ShowSQL(true)
}
func Close() {
	defer DB.Close()
}

//func InsertEmail(email entity.Email) {
//	_, err := DB.Insert(&email)
//	if err != nil {
//		log.Fatalf("插入数据时出错: %s", err)
//	}
//	fmt.Println("数据插入成功")
//}
//
//func GetEmails() {
//	var emails []entity.Email
//	err := DB.Find(&emails)
//	if err != nil {
//		log.Fatal(err)
//	}
//
//	for _, email := range emails {
//		fmt.Printf("%+v\n", email)
//	}
//}
//func GetEmailById() {
//	var emails []entity.Email
//	err := DB.ID(&emails)
//	if err != nil {
//		log.Fatal(err)
//	}
//
//	for _, email := range emails {
//		fmt.Printf("%+v\n", email)
//	}
//}
//
//func UpdateEmail(id int64, newEmail string) {
//	email := new(entity.Email)
//	has, err := DB.ID(id).Get(email)
//	if err != nil {
//		log.Fatal(err)
//	}
//	if !has {
//		fmt.Println("数据未找到")
//		return
//	}
//
//	email.Email = newEmail
//	_, err = DB.ID(id).Update(email)
//	if err != nil {
//		log.Fatalf("更新数据时出错: %s", err)
//	}
//	fmt.Println("数据更新成功")
//}
//
//func DeleteEmail(id int64) {
//	_, err := DB.ID(id).Delete(&entity.Email{})
//	if err != nil {
//		log.Fatalf("删除数据时出错: %s", err)
//	}
//	fmt.Println("数据删除成功")
//}