database

package

v1.4.4 Latest Latest Go to latest Published: Feb 6, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func GetSlice(db *Database, query string) (any, error)

func PrepareSliceQuery(queryTemplate, sliceTemplate string, slice []any, args ...any) (string, []any, error)

type Database struct {
	ConnectionString string `yaml:"connection_string,omitempty" json:"connection_string,omitempty"`
}

func (d *Database) Deploy(listFile string) (err error)

func (d *Database) NewSession(withTransaction bool) (*Session, error)

type Filter map[string]string

func (f *Filter) Render(queryTemplate string, config *FilterConfig, args ...any) (string, []any, error)

type FilterConfig struct {
	Join       string
	Parameters map[string]*FilterParameter
}

type FilterParameter struct {
	IsSlice bool
	Value   string
	Item    string
	Join    string
}

type Session struct {
	// contains filtered or unexported fields
}

func (s *Session) Close() error

func (s *Session) Commit() error

func (s *Session) Exec(query string, args ...any) (int64, error)

func (s *Session) InsertRow(query string, args ...any) (int64, error)

func (s *Session) Query(query string, args ...any) (*sql.Rows, error)

func (s *Session) QueryRow(query string, args ...any) (*sql.Row, error)

func (s *Session) Rollback() error

func (s *Session) SelectSet(query string, args ...any) (*set.Set[string], error)