sqlite.go 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package sqlite
  2. import (
  3. "database/sql"
  4. "github.com/jinzhu/gorm"
  5. "github.com/jinzhu/gorm/callbacks"
  6. "github.com/jinzhu/gorm/migrator"
  7. "github.com/jinzhu/gorm/schema"
  8. _ "github.com/mattn/go-sqlite3"
  9. )
  10. type Dialector struct {
  11. DSN string
  12. }
  13. func Open(dsn string) gorm.Dialector {
  14. return &Dialector{DSN: dsn}
  15. }
  16. func (dialector Dialector) Initialize(db *gorm.DB) (err error) {
  17. // register callbacks
  18. callbacks.RegisterDefaultCallbacks(db)
  19. db.DB, err = sql.Open("sqlite3", dialector.DSN)
  20. return
  21. }
  22. func (dialector Dialector) Migrator(db *gorm.DB) gorm.Migrator {
  23. return Migrator{migrator.Migrator{Config: migrator.Config{
  24. DB: db,
  25. Dialector: dialector,
  26. }}}
  27. }
  28. func (dialector Dialector) BindVar(stmt *gorm.Statement, v interface{}) string {
  29. return "?"
  30. }
  31. func (dialector Dialector) QuoteChars() [2]byte {
  32. return [2]byte{'`', '`'} // `name`
  33. }
  34. func (dialector Dialector) DataTypeOf(field *schema.Field) string {
  35. switch field.DataType {
  36. case schema.Bool:
  37. return "NUMERIC"
  38. case schema.Int, schema.Uint:
  39. if field.AutoIncrement {
  40. // https://www.sqlite.org/autoinc.html
  41. return "INTEGER PRIMARY KEY AUTOINCREMENT"
  42. } else {
  43. return "INTEGER"
  44. }
  45. case schema.Float:
  46. return "REAL"
  47. case schema.String, schema.Time:
  48. return "TEXT"
  49. case schema.Bytes:
  50. return "BLOB"
  51. }
  52. return ""
  53. }