Documentation ¶
Overview ¶
So what does Pop do exactly? Well, it wraps the absolutely amazing https://github.com/jmoiron/sqlx library. It cleans up some of the common patterns and workflows usually associated with dealing with databases in Go.
Pop makes it easy to do CRUD operations, run migrations, and build/execute queries. Is Pop an ORM? I'll leave that up to you, the reader, to decide.
Pop, by default, follows conventions that were defined by the ActiveRecord Ruby gem, http://www.rubyonrails.org. What does this mean?
* Tables must have an "id" column and a corresponding "ID" field on the `struct` being used. * If there is a timestamp column named "created_at", "CreatedAt" on the `struct`, it will be set with the current time when the record is created. * If there is a timestamp column named "updated_at", "UpdatedAt" on the `struct`, it will be set with the current time when the record is updated. * Default databases are lowercase, underscored versions of the `struct` name. Examples: User{} is "users", FooBar{} is "foo_bars", etc...
Index ¶
- Variables
- func AddLookupPaths(paths ...string) error
- func CreateDB(c *Connection) error
- func DropDB(c *Connection) error
- func LoadConfigFile() error
- func LoadFrom(r io.Reader) error
- func LookupPaths() []string
- func MapTableName(name string, tableName string)
- func MigrationCreate(path, name, ext string, up, down []byte) error
- type Connection
- func (c *Connection) All(models interface{}) error
- func (c *Connection) BelongsTo(model interface{}) *Query
- func (c *Connection) BelongsToThrough(bt, thru interface{}) *Query
- func (c *Connection) Close() error
- func (c *Connection) Count(model interface{}) (int, error)
- func (c *Connection) Create(model interface{}, excludeColumns ...string) error
- func (c *Connection) Destroy(model interface{}) error
- func (c *Connection) Find(model interface{}, id interface{}) error
- func (c *Connection) First(model interface{}) error
- func (c *Connection) Last(model interface{}) error
- func (c *Connection) Limit(limit int) *Query
- func (c *Connection) MigrateDown(path string, step int) error
- func (c *Connection) MigrateReset(path string) error
- func (c *Connection) MigrateStatus(path string) error
- func (c *Connection) MigrateUp(path string) error
- func (c *Connection) MigrationURL() string
- func (c *Connection) NewTransaction() (*Connection, error)
- func (c *Connection) Open() error
- func (c *Connection) Order(stmt string) *Query
- func (c *Connection) Paginate(page int, per_page int) *Query
- func (c *Connection) PaginateFromParams(params PaginationParams) *Query
- func (c *Connection) Q() *Query
- func (c *Connection) RawQuery(stmt string, args ...interface{}) *Query
- func (c *Connection) Reload(model interface{}) error
- func (c *Connection) Rollback(fn func(tx *Connection)) error
- func (c *Connection) Save(model interface{}, excludeColumns ...string) error
- func (c *Connection) Scope(sf ScopeFunc) *Query
- func (c *Connection) String() string
- func (c *Connection) Transaction(fn func(tx *Connection) error) error
- func (c *Connection) TruncateAll() error
- func (c *Connection) URL() string
- func (c *Connection) Update(model interface{}, excludeColumns ...string) error
- func (c *Connection) ValidateAndCreate(model interface{}, excludeColumns ...string) (*validate.Errors, error)
- func (c *Connection) ValidateAndSave(model interface{}, excludeColumns ...string) (*validate.Errors, error)
- func (c *Connection) ValidateAndUpdate(model interface{}, excludeColumns ...string) (*validate.Errors, error)
- func (c *Connection) Where(stmt string, args ...interface{}) *Query
- type ConnectionDetails
- type FileMigrator
- type GroupClause
- type HavingClause
- type Migration
- type MigrationBox
- type Migrations
- type Migrator
- type Model
- type PaginationParams
- type Paginator
- type Query
- func (q *Query) All(models interface{}) error
- func (q *Query) BelongsTo(model interface{}) *Query
- func (q *Query) BelongsToThrough(bt, thru interface{}) *Query
- func (q Query) Count(model interface{}) (int, error)
- func (q Query) CountByField(model interface{}, field string) (int, error)
- func (q *Query) Exec() error
- func (q *Query) Exists(model interface{}) (bool, error)
- func (q *Query) Find(model interface{}, id interface{}) error
- func (q *Query) First(model interface{}) error
- func (q *Query) GroupBy(field string, fields ...string) *Query
- func (q *Query) Having(condition string, args ...interface{}) *Query
- func (q *Query) Join(table string, on string, args ...interface{}) *Query
- func (q *Query) Last(model interface{}) error
- func (q *Query) LeftInnerJoin(table string, on string, args ...interface{}) *Query
- func (q *Query) LeftJoin(table string, on string, args ...interface{}) *Query
- func (q *Query) LeftOuterJoin(table string, on string, args ...interface{}) *Query
- func (q *Query) Limit(limit int) *Query
- func (q *Query) Order(stmt string) *Query
- func (q *Query) Paginate(page int, per_page int) *Query
- func (q *Query) PaginateFromParams(params PaginationParams) *Query
- func (q *Query) RawQuery(stmt string, args ...interface{}) *Query
- func (q *Query) RightInnerJoin(table string, on string, args ...interface{}) *Query
- func (q *Query) RightJoin(table string, on string, args ...interface{}) *Query
- func (q *Query) RightOuterJoin(table string, on string, args ...interface{}) *Query
- func (q *Query) Scope(sf ScopeFunc) *Query
- func (q Query) ToSQL(model *Model, addColumns ...string) (string, []interface{})
- func (q *Query) Where(stmt string, args ...interface{}) *Query
- type ScopeFunc
- type Value
Constants ¶
This section is empty.
Variables ¶
var Color = true
var ConfigName = "database.yml"
var Connections = map[string]*Connection{}
Connections contains all of the available connections
var Debug = false
var Log = func(s string, args ...interface{}) { if Debug { if len(args) > 0 { xargs := make([]string, len(args)) for i, a := range args { switch a.(type) { case string: xargs[i] = fmt.Sprintf("%q", a) default: xargs[i] = fmt.Sprintf("%v", a) } } s = fmt.Sprintf("%s | %s", s, xargs) } if Color { s = color.YellowString(s) } logger.Println(s) } }
var PaginatorPageKey = "page"
var PaginatorPerPageDefault = 20
var PaginatorPerPageKey = "per_page"
Functions ¶
func AddLookupPaths ¶
func CreateDB ¶
func CreateDB(c *Connection) error
func DropDB ¶
func DropDB(c *Connection) error
func LoadConfigFile ¶
func LoadConfigFile() error
func LookupPaths ¶
func LookupPaths() []string
func MapTableName ¶
MapTableName allows for the customize table mapping between a name and the database. For example the value `User{}` will automatically map to "users". MapTableName would allow this to change.
m := &pop.Model{Value: User{}} m.TableName() // "users" pop.MapTableName("user", "people") m = &pop.Model{Value: User{}} m.TableName() // "people"
func MigrationCreate ¶
Types ¶
type Connection ¶
Connection represents all of the necessary details for talking with a datastore
func Connect ¶
func Connect(e string) (*Connection, error)
Connect takes the name of a connection, default is "development", and will return that connection from the available `Connections`. If a connection with that name can not be found an error will be returned. If a connection is found, and it has yet to open a connection with its underlying datastore, a connection to that store will be opened.
func NewConnection ¶
func NewConnection(deets *ConnectionDetails) (*Connection, error)
NewConnection creates a new connection, and sets it's `Dialect` appropriately based on the `ConnectionDetails` passed into it.
func (*Connection) All ¶
func (c *Connection) All(models interface{}) error
All retrieves all of the records in the database that match the query.
c.All(&[]User{})
func (*Connection) BelongsTo ¶
func (c *Connection) BelongsTo(model interface{}) *Query
BelongsTo adds a "where" clause based on the "ID" of the "model" passed into it.
func (*Connection) BelongsToThrough ¶
func (c *Connection) BelongsToThrough(bt, thru interface{}) *Query
BelongsToThrough adds a "where" clause that connects the "bt" model through the associated "thru" model.
func (*Connection) Close ¶
func (c *Connection) Close() error
func (*Connection) Count ¶
func (c *Connection) Count(model interface{}) (int, error)
Count the number of records in the database.
c.Count(&User{})
func (*Connection) Create ¶
func (c *Connection) Create(model interface{}, excludeColumns ...string) error
func (*Connection) Destroy ¶
func (c *Connection) Destroy(model interface{}) error
func (*Connection) Find ¶
func (c *Connection) Find(model interface{}, id interface{}) error
Find the first record of the model in the database with a particular id.
c.Find(&User{}, 1)
func (*Connection) First ¶
func (c *Connection) First(model interface{}) error
First record of the model in the database that matches the query.
c.First(&User{})
func (*Connection) Last ¶
func (c *Connection) Last(model interface{}) error
Last record of the model in the database that matches the query.
c.Last(&User{})
func (*Connection) Limit ¶
func (c *Connection) Limit(limit int) *Query
Limit will add a limit clause to the query.
func (*Connection) MigrateDown ¶
func (c *Connection) MigrateDown(path string, step int) error
MigrateDown is deprecated, and will be removed in a future version. Use FileMigrator#Down instead.
func (*Connection) MigrateReset ¶
func (c *Connection) MigrateReset(path string) error
MigrateReset is deprecated, and will be removed in a future version. Use FileMigrator#Reset instead.
func (*Connection) MigrateStatus ¶
func (c *Connection) MigrateStatus(path string) error
MigrateStatus is deprecated, and will be removed in a future version. Use FileMigrator#Status instead.
func (*Connection) MigrateUp ¶
func (c *Connection) MigrateUp(path string) error
MigrateUp is deprecated, and will be removed in a future version. Use FileMigrator#Up instead.
func (*Connection) MigrationURL ¶
func (c *Connection) MigrationURL() string
func (*Connection) NewTransaction ¶
func (c *Connection) NewTransaction() (*Connection, error)
func (*Connection) Open ¶
func (c *Connection) Open() error
func (*Connection) Order ¶
func (c *Connection) Order(stmt string) *Query
Order will append an order clause to the query.
c.Order("name desc")
func (*Connection) Paginate ¶
func (c *Connection) Paginate(page int, per_page int) *Query
Paginate records returned from the database.
q := c.Paginate(2, 15) q.All(&[]User{}) q.Paginator
func (*Connection) PaginateFromParams ¶
func (c *Connection) PaginateFromParams(params PaginationParams) *Query
Paginate records returned from the database.
q := c.PaginateFromParams(req.URL.Query()) q.All(&[]User{}) q.Paginator
func (*Connection) Q ¶
func (c *Connection) Q() *Query
Q creates a new "empty" query for the current connection.
func (*Connection) RawQuery ¶
func (c *Connection) RawQuery(stmt string, args ...interface{}) *Query
RawQuery will override the query building feature of Pop and will use whatever query you want to execute against the `Connection`. You can continue to use the `?` argument syntax.
c.RawQuery("select * from foo where id = ?", 1)
func (*Connection) Reload ¶
func (c *Connection) Reload(model interface{}) error
func (*Connection) Rollback ¶
func (c *Connection) Rollback(fn func(tx *Connection)) error
Rollback will open a new transaction and automatically rollback that transaction when the inner function returns, regardless. This can be useful for tests, etc...
func (*Connection) Save ¶
func (c *Connection) Save(model interface{}, excludeColumns ...string) error
func (*Connection) Scope ¶
func (c *Connection) Scope(sf ScopeFunc) *Query
Scope the query by using a `ScopeFunc`
func ByName(name string) ScopeFunc { return func(q *Query) *Query { return q.Where("name = ?", name) } } c.Scope(ByName("mark")).First(&User{})
func (*Connection) String ¶
func (c *Connection) String() string
func (*Connection) Transaction ¶
func (c *Connection) Transaction(fn func(tx *Connection) error) error
Transaction will start a new transaction on the connection. If the inner function returns an error then the transaction will be rolled back, otherwise the transaction will automatically commit at the end.
func (*Connection) TruncateAll ¶
func (c *Connection) TruncateAll() error
func (*Connection) URL ¶
func (c *Connection) URL() string
func (*Connection) Update ¶
func (c *Connection) Update(model interface{}, excludeColumns ...string) error
func (*Connection) ValidateAndCreate ¶
func (c *Connection) ValidateAndCreate(model interface{}, excludeColumns ...string) (*validate.Errors, error)
func (*Connection) ValidateAndSave ¶
func (c *Connection) ValidateAndSave(model interface{}, excludeColumns ...string) (*validate.Errors, error)
func (*Connection) ValidateAndUpdate ¶
func (c *Connection) ValidateAndUpdate(model interface{}, excludeColumns ...string) (*validate.Errors, error)
func (*Connection) Where ¶
func (c *Connection) Where(stmt string, args ...interface{}) *Query
Where will append a where clause to the query. You may use `?` in place of arguments.
c.Where("id = ?", 1) q.Where("id in (?)", 1, 2, 3)
type ConnectionDetails ¶
type ConnectionDetails struct { // Example: "postgres" or "sqlite3" or "mysql" Dialect string // The name of your database. Example: "foo_development" Database string // The host of your database. Example: "127.0.0.1" Host string // The port of your database. Example: 1234 // Will default to the "default" port for each dialect. Port string // The username of the database user. Example: "root" User string // The password of the database user. Example: "password" Password string // Instead of specifying each individual piece of the // connection you can instead just specify the URL of the // database. Example: "postgres://postgres:postgres@localhost:5432/pop_test?sslmode=disable" URL string // Defaults to 0 "unlimited". See https://golang.org/pkg/database/sql/#DB.SetMaxOpenConns Pool int Options map[string]string }
func (*ConnectionDetails) Finalize ¶
func (cd *ConnectionDetails) Finalize() error
Finalize cleans up the connection details by normalizing names, filling in default values, etc...
func (*ConnectionDetails) Parse ¶
func (cd *ConnectionDetails) Parse(port string) error
Parse is deprecated! Please use `ConnectionDetails.Finalize()` instead!
func (*ConnectionDetails) RetryLimit ¶
func (cd *ConnectionDetails) RetryLimit() int
func (*ConnectionDetails) RetrySleep ¶
func (cd *ConnectionDetails) RetrySleep() time.Duration
type FileMigrator ¶
FileMigrator is a migrator for SQL and Fizz files on disk at a specified path.
func NewFileMigrator ¶
func NewFileMigrator(path string, c *Connection) (FileMigrator, error)
NewFileMigrator for a path and a Connection
type GroupClause ¶
type GroupClause struct {
Field string
}
func (GroupClause) String ¶
func (c GroupClause) String() string
type HavingClause ¶
type HavingClause struct { Condition string Arguments []interface{} }
func (HavingClause) String ¶
func (c HavingClause) String() string
type Migration ¶
type Migration struct { // Path to the migration (./migrations/123_create_widgets.up.sql) Path string // Version of the migration (123) Version string // Name of the migration (create_widgets) Name string // Direction of the migration (up) Direction string // Type of migration (sql) Type string // Runner function to run/execute the migration Runner func(Migration, *Connection) error }
func (Migration) Run ¶
func (mf Migration) Run(c *Connection) error
Run the migration. Returns an error if there is no mf.Runner defined.
type MigrationBox ¶
MigrationBox is a wrapper around packr.Box and Migrator. This will allow you to run migrations from a packed box inside of a compiled binary.
func NewMigrationBox ¶
func NewMigrationBox(box packr.Box, c *Connection) (MigrationBox, error)
NewMigrationBox from a packr.Box and a Connection.
type Migrations ¶
type Migrations []Migration
func (Migrations) Len ¶
func (mfs Migrations) Len() int
func (Migrations) Less ¶
func (mfs Migrations) Less(i, j int) bool
func (Migrations) Swap ¶
func (mfs Migrations) Swap(i, j int)
type Migrator ¶
type Migrator struct { Connection *Connection SchemaPath string Migrations map[string]Migrations }
Migrator forms the basis of all migrations systems. It does the actual heavy lifting of running migrations. When building a new migration system, you should embed this type into your migrator.
func NewMigrator ¶
func NewMigrator(c *Connection) Migrator
NewMigrator returns a new "blank" migrator. It is recommended to use something like MigrationBox or FileMigrator. A "blank" Migrator should only be used as the basis for a new type of migration system.
func (Migrator) CreateSchemaMigrations ¶
CreateSchemaMigrations sets up a table to track migrations. This is an idempotent operation.
func (Migrator) Down ¶
Down runs pending "down" migrations and rolls back the database by the specified number of steps.
func (Migrator) DumpMigrationSchema ¶
DumpMigrationSchema will generate a file of the current database schema based on the value of Migrator.SchemaPath
func (Migrator) Reset ¶
Reset the database by runing the down migrations followed by the up migrations.
type Model ¶
Model is used throughout Pop to wrap the end user interface that is passed in to many functions.
func (*Model) ID ¶
func (m *Model) ID() interface{}
ID returns the ID of the Model. All models must have an `ID` field this is of type `int`,`int64` or of type `uuid.UUID`.
func (*Model) PrimaryKeyType ¶
type PaginationParams ¶
type Paginator ¶
type Paginator struct { // Current page you're on Page int `json:"page"` // Number of results you want per page PerPage int `json:"per_page"` // Page * PerPage (ex: 2 * 20, Offset == 40) Offset int `json:"offset"` // Total potential records matching the query TotalEntriesSize int `json:"total_entries_size"` // Total records returns, will be <= PerPage CurrentEntriesSize int `json:"current_entries_size"` // Total pages TotalPages int `json:"total_pages"` }
Paginator is a type used to represent the pagination of records from the database.
func NewPaginator ¶
NewPaginator returns a new `Paginator` value with the appropriate defaults set.
func NewPaginatorFromParams ¶
func NewPaginatorFromParams(params PaginationParams) *Paginator
NewPaginatorFromParams takes an interface of type `PaginationParams`, the `url.Values` type works great with this interface, and returns a new `Paginator` based on the params or `PaginatorPageKey` and `PaginatorPerPageKey`. Defaults are `1` for the page and PaginatorPerPageDefault for the per page value.
type Query ¶
type Query struct { RawSQL *clause Paginator *Paginator Connection *Connection // contains filtered or unexported fields }
Query is the main value that is used to build up a query to be executed against the `Connection`.
func Q ¶
func Q(c *Connection) *Query
Q will create a new "empty" query from the current connection.
func (*Query) All ¶
All retrieves all of the records in the database that match the query.
q.Where("name = ?", "mark").All(&[]User{})
func (*Query) BelongsTo ¶
BelongsTo adds a "where" clause based on the "ID" of the "model" passed into it.
func (*Query) BelongsToThrough ¶
BelongsToThrough adds a "where" clause that connects the "bt" model through the associated "thru" model.
func (Query) Count ¶
Count the number of records in the database.
q.Where("name = ?", "mark").Count(&User{})
func (Query) CountByField ¶
func (*Query) Exists ¶
Exists returns true/false if a record exists in the database that matches the query.
q.Where("name = ?", "mark").Exists(&User{})
func (*Query) Find ¶
Find the first record of the model in the database with a particular id.
q.Find(&User{}, 1)
func (*Query) First ¶
First record of the model in the database that matches the query.
q.Where("name = ?", "mark").First(&User{})
func (*Query) Last ¶
Last record of the model in the database that matches the query.
q.Where("name = ?", "mark").Last(&User{})
func (*Query) LeftInnerJoin ¶
func (*Query) LeftOuterJoin ¶
func (*Query) Paginate ¶
Paginate records returned from the database.
q = q.Paginate(2, 15) q.All(&[]User{}) q.Paginator
func (*Query) PaginateFromParams ¶
func (q *Query) PaginateFromParams(params PaginationParams) *Query
Paginate records returned from the database.
q = q.PaginateFromParams(req.URL.Query()) q.All(&[]User{}) q.Paginator
func (*Query) RawQuery ¶
RawQuery will override the query building feature of Pop and will use whatever query you want to execute against the `Connection`. You can continue to use the `?` argument syntax.
q.RawQuery("select * from foo where id = ?", 1)
func (*Query) RightInnerJoin ¶
func (*Query) RightOuterJoin ¶
func (*Query) Scope ¶
Scope the query by using a `ScopeFunc`
func ByName(name string) ScopeFunc { return func(q *Query) *Query { return q.Where("name = ?", name) } } q.Scope(ByName("mark").Where("id = ?", 1).First(&User{})
Source Files ¶
- belongs_to.go
- callbacks.go
- clause.go
- commands.go
- config.go
- connection.go
- connection_details.go
- db.go
- dialect.go
- doc.go
- executors.go
- file_migrator.go
- finders.go
- group.go
- having.go
- join.go
- migration.go
- migration_box.go
- migration_info.go
- migrator.go
- model.go
- mysql.go
- paginator.go
- pop.go
- postgresql.go
- query.go
- query_groups.go
- query_having.go
- query_joins.go
- schema_migrations.go
- scopes.go
- sql_builder.go
- sqlite.go
- store.go
- tx.go
- validations.go