ansi

Documentation

Index

• type ConnectionStatements
• type DatabaseStatements
  • func (s *DatabaseStatements) ExecDelete(ctx context.Context, op *activerecord.DeleteOperation) error
  • func (s *DatabaseStatements) ExecInsert(ctx context.Context, op *activerecord.InsertOperation) (id interface{}, err error)
  • func (s *DatabaseStatements) ExecQuery(ctx context.Context, op *activerecord.QueryOperation, cb func(Hash) bool) (err error)
  • func (s *DatabaseStatements) ExecUpdate(ctx context.Context, op *activerecord.UpdateOperation) error
• type SchemaStatements
  • func (s *SchemaStatements) AddForeignKey(ctx context.Context, owner, target string) error
  • func (s *SchemaStatements) ColumnDefinitions(ctx context.Context, tableName string) ([]activerecord.ColumnDefinition, error)
  • func (s *SchemaStatements) ColumnType(typeName string) (activerecord.Type, error)
  • func (s *SchemaStatements) CreateTable(ctx context.Context, table *activerecord.Table) error

Types

type ConnectionStatements

type ConnectionStatements interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
}

type DatabaseStatements

type DatabaseStatements struct {
	Conn ConnectionStatements
}

func (*DatabaseStatements) ExecDelete

func (s *DatabaseStatements) ExecDelete(ctx context.Context, op *activerecord.DeleteOperation) error

func (*DatabaseStatements) ExecInsert

func (s *DatabaseStatements) ExecInsert(ctx context.Context, op *activerecord.InsertOperation) (
	id interface{}, err error,
)

func (*DatabaseStatements) ExecQuery

func (s *DatabaseStatements) ExecQuery(
	ctx context.Context, op *activerecord.QueryOperation, cb func(Hash) bool,
) (
	err error,
)

func (*DatabaseStatements) ExecUpdate

func (s *DatabaseStatements) ExecUpdate(
	ctx context.Context, op *activerecord.UpdateOperation,
) error

type SchemaStatements

type SchemaStatements struct {
	Conn ConnectionStatements
}

func (*SchemaStatements) AddForeignKey

func (s *SchemaStatements) AddForeignKey(ctx context.Context, owner, target string) error

func (*SchemaStatements) ColumnDefinitions

func (s *SchemaStatements) ColumnDefinitions(ctx context.Context, tableName string) (
	[]activerecord.ColumnDefinition, error,
)

func (*SchemaStatements) ColumnType

func (s *SchemaStatements) ColumnType(typeName string) (activerecord.Type, error)

func (*SchemaStatements) CreateTable

func (s *SchemaStatements) CreateTable(ctx context.Context, table *activerecord.Table) error