redisdog/src/cnphper.com/model/syscfg.go

package model

import (
	"database/sql"
	"errors"
)

type SysCfg struct {
	Model
}

type SysCfgRow struct {
	Id       int64
	CfgKey   string
	CfgValue string
}

func NewSysCfg(db *sql.DB) *SysCfg {
	return &SysCfg{
		Model{
			db: db,
		},
	}
}

func (m *SysCfg) Insert(key, value string) (int64, error) {
	if key == "" {
		return 0, errors.New("KEY不能为空")
	}
	ret, err := m.db.Exec("insert into syscfg(cfg_key,cfg_value) values(?,?)", key, value)
	if err != nil {
		return 0, err
	} else {
		return ret.LastInsertId()
	}
}

func (m *SysCfg) Delete(id int64) (int64, error) {
	if id <= 0 {
		return 0, errors.New("ID必须是正整数")
	}
	ret, err := m.db.Exec("delete from syscfg where id=?", id)
	if err != nil {
		return 0, err
	} else {
		return ret.RowsAffected()
	}
}

func (m *SysCfg) DeleteByKey(key string) (int64, error) {
	if key == "" {
		return 0, errors.New("KEY不能为空")
	}
	ret, err := m.db.Exec("delete from syscfg where cfg_key=?", key)
	if err != nil {
		return 0, err
	} else {
		return ret.RowsAffected()
	}
}

func (m *SysCfg) Update(id int64, value string) (int64, error) {
	if id <= 0 {
		return 0, errors.New("ID必须是正整数")
	}
	ret, err := m.db.Exec("update syscfg set cfg_value=? where id=?", value, id)
	if err != nil {
		return 0, err
	} else {
		return ret.RowsAffected()
	}
}

func (m *SysCfg) UpdateByKey(key, value string) (int64, error) {
	if key == "" {
		return 0, errors.New("KEY不能为空")
	}
	ret, err := m.db.Exec("update syscfg set cfg_value=? where cfg_key=?", value, key)
	if err != nil {
		return 0, err
	} else {
		return ret.RowsAffected()
	}
}

func (m *SysCfg) Get(id int64) (*SysCfgRow, error) {
	if id <= 0 {
		return nil, errors.New("ID必须是正整数")
	}
	result := m.db.QueryRow("select id,cfg_key,cfg_value from syscfg where id=?", id)
	row := SysCfgRow{}
	err := result.Scan(&row.Id, &row.CfgKey, &row.CfgValue)
	if err != nil {
		if err == sql.ErrNoRows {
			return nil, errors.New("记录不存在")
		} else {
			return nil, err
		}
	} else {
		return &row, nil
	}
}

func (m *SysCfg) GetByKey(key string) (*SysCfgRow, error) {
	if key == "" {
		return nil, errors.New("KEY不能为空")
	}
	result := m.db.QueryRow("select id,cfg_key,cfg_value from syscfg where cfg_key=?", key)
	row := SysCfgRow{}
	err := result.Scan(&row.Id, &row.CfgKey, &row.CfgValue)
	if err != nil {
		if err == sql.ErrNoRows {
			return nil, errors.New("记录不存在")
		} else {
			return nil, err
		}
	} else {
		return &row, nil
	}
}

func (m *SysCfg) GetAll() ([]*SysCfgRow, error) {
	result, err := m.db.Query("select id,cfg_key,cfg_value from syscfg order by id")
	if err != nil {
		return nil, err
	}
	rows := make([]*SysCfgRow, 0)
	for result.Next() {
		row := SysCfgRow{}
		err = result.Scan(&row.Id, &row.CfgKey, &row.CfgValue)
		if err != nil {
			continue
		}
		rows = append(rows, &row)
	}
	return rows, nil
}