session

models/session.go

@@ -0,0 +1,176 @@
+package models
+
+import (
+	"log"
+	"main/configs"
+)
+
+type Session struct {
+	ID        int    `json:"id"`
+	Name      string `json:"name"`
+	CreatedAt string `json:"created_at"`
+	UpdatedAt string `json:"updated_at"`
+}
+
+func (session *Session) Get() {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	defer db.Close()
+	row := db.QueryRow("SELECT * FROM sessions WHERE id = ?", session.ID)
+	err = row.Scan(&session.ID, &session.Name, &session.CreatedAt, &session.UpdatedAt)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+}
+
+func (session *Session) Create() error {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	defer db.Close()
+	stmt, err := db.Prepare("INSERT INTO sessions(name) values(?)")
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	defer stmt.Close()
+	result, err := stmt.Exec(session.Name)
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	id, err := result.LastInsertId()
+	if err != nil {
+		return err
+	}
+	session.ID = int(id)
+	return nil
+}
+
+func (session *Session) Delete() error {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	defer db.Close()
+	stmt, err := db.Prepare("DELETE FROM sessions WHERE id = ?")
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	defer stmt.Close()
+	_, err = stmt.Exec(session.ID)
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	return nil
+}
+
+func (session *Session) Update() error {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	defer db.Close()
+	stmt, err := db.Prepare("UPDATE sessions SET name = ? WHERE id = ?")
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	defer stmt.Close()
+	_, err = stmt.Exec(session.Name, session.ID)
+	if err != nil {
+		log.Println(err)
+		return err
+	}
+	return nil
+}
+
+func GetSessions() ([]Session, error) {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return nil, err
+	}
+	defer db.Close()
+	rows, err := db.Query("SELECT id, name FROM sessions")
+	if err != nil {
+		log.Println(err)
+		return nil, err
+	}
+	defer rows.Close()
+	sessions := []Session{}
+	for rows.Next() {
+		var session Session
+		if err := rows.Scan(&session.ID, &session.Name); err != nil {
+			log.Println(err)
+			return nil, err
+		}
+		sessions = append(sessions, session)
+	}
+	return sessions, nil
+}
+
+func GetSession(id int) (*Session, error) {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return nil, err
+	}
+	defer db.Close()
+	row := db.QueryRow("SELECT id, name FROM sessions WHERE id = ?", id)
+	var session Session
+	if err := row.Scan(&session.ID, &session.Name); err != nil {
+		log.Println(err)
+		return nil, err
+	}
+	return &session, nil
+}
+
+func QuerySessions(page, pagesize int) (list []interface{}) {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	defer db.Close()
+	rows, err := db.Query("SELECT id, name FROM sessions LIMIT ?, ?", (page-1)*pagesize, pagesize)
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	defer rows.Close()
+	for rows.Next() {
+		var session Session
+		if err := rows.Scan(&session.ID, &session.Name); err != nil {
+			log.Println(err)
+			return
+		}
+		list = append(list, session)
+	}
+	return
+}
+
+func CountSessions() (count int) {
+	db, err := configs.GetDB()
+	if err != nil {
+		log.Println(err)
+		return
+	}
+	defer db.Close()
+	row := db.QueryRow("SELECT COUNT(*) FROM sessions")
+	if err := row.Scan(&count); err != nil {
+		log.Println(err)
+		return
+	}
+	return
+}