package gorm import ( "database/sql" "errors" "strconv" ) type Orm struct { TableName string PrimaryKey string SqlResult sql.Result Error error Sql string SqlVars []interface{} model *Model db *sql.DB driver string whereClause []map[string]interface{} orClause []map[string]interface{} notClause []map[string]interface{} selectStr string orderStrs []string offsetStr string limitStr string operation string } func (s *Orm) Model(model interface{}) *Orm { s.model = s.toModel(model) s.TableName = s.model.TableName() s.PrimaryKey = s.model.PrimaryKeyDb() return s } func (s *Orm) Where(querystring interface{}, args ...interface{}) *Orm { s.whereClause = append(s.whereClause, map[string]interface{}{"query": querystring, "args": args}) return s } func (s *Orm) Limit(value interface{}) *Orm { switch value := value.(type) { case string: s.limitStr = value case int: if value < 0 { s.limitStr = "" } else { s.limitStr = strconv.Itoa(value) } default: s.Error = errors.New("Can' understand the value of Limit, Should be int") } return s } func (s *Orm) Offset(value interface{}) *Orm { switch value := value.(type) { case string: s.offsetStr = value case int: if value < 0 { s.offsetStr = "" } else { s.offsetStr = strconv.Itoa(value) } default: s.Error = errors.New("Can' understand the value of Offset, Should be int") } return s } func (s *Orm) Order(value string, reorder ...bool) *Orm { defer s.validSql(value) if len(reorder) > 0 && reorder[0] { s.orderStrs = append([]string{}, value) } else { s.orderStrs = append(s.orderStrs, value) } return s } func (s *Orm) Count() int64 { return 0 } func (s *Orm) Select(value interface{}) *Orm { defer func() { s.validSql(s.selectStr) }() switch value := value.(type) { case string: s.selectStr = value default: s.Error = errors.New("Can' understand the value of Select, Should be string") } return s } func (s *Orm) Save(value interface{}) *Orm { s.Model(value) if s.model.PrimaryKeyIsEmpty() { s.explain(value, "Create").create(value) } else { s.explain(value, "Update").update(value) } return s } func (s *Orm) Delete(value interface{}) *Orm { s.explain(value, "Delete").Exec() return s } func (s *Orm) Update(column string, value string) *Orm { return s } func (s *Orm) Updates(values map[string]string) *Orm { return s } func (s *Orm) Exec(sql ...string) *Orm { if len(sql) == 0 { s.SqlResult, s.Error = s.db.Exec(s.Sql, s.SqlVars...) } else { s.SqlResult, s.Error = s.db.Exec(sql[0]) } return s } func (s *Orm) First(out interface{}) *Orm { s.explain(out, "Query").query(out) return s } func (s *Orm) Find(out interface{}) *Orm { s.explain(out, "Query").query(out) return s } func (s *Orm) Pluck(column string, value interface{}) (orm *Orm) { s.Select(column).explain(s.model.Data, "Query").pluck(value) return s } func (s *Orm) Or(querystring interface{}, args ...interface{}) *Orm { s.orClause = append(s.orClause, map[string]interface{}{"query": querystring, "args": args}) return s } func (s *Orm) Not(querystring interface{}, args ...interface{}) *Orm { s.notClause = append(s.notClause, map[string]interface{}{"query": querystring, "args": args}) return s } func (s *Orm) CreateTable(value interface{}) *Orm { s.explain(value, "CreateTable").Exec() return s }