data

Documentation

Index

• Constants
• type DAO
  • func NewStore(driver DataDriver) *DAO
  • func (s *DAO) GetUsers() ([]*model.User, error)
  • func (d *DAO) GetUsersByEmail(email string) ([]*model.User, error)
  • func (s *DAO) GetUsersByEmailDomain(domain string) ([]*model.User, error)
• type DataDriver
• type DuckDBDriver
  • func NewDuckDBDriver(awsCred aws.AWSCred) *DuckDBDriver
  • func (d *DuckDBDriver) Close() error
  • func (d *DuckDBDriver) Execute(statement string) error
  • func (d *DuckDBDriver) Query(statement string) (*sql.Rows, error)
  • func (d *DuckDBDriver) QueryPreparedStatement(query string, v string) (*sql.Rows, error)

Constants

const (
	StmntLoadUsersTable = "CREATE TABLE users AS select id, account_id, email, department, " +
		"created_date, first_name, last_name, account_status, active_package_name, account_record_type " +
		"from read_parquet('%s') "
	QryAllUsers      = "SELECT id, account_id, email, department, created_date FROM users limit 100;"
	QryUsersByDomain = "SELECT id, account_id, email, department, created_date FROM users WHERE email LIKE ?"
	QryUsersByEmail  = "SELECT id, account_id, email, department, created_date FROM users WHERE email = ?"
)

Types

type DAO

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

func NewStore

func NewStore(driver DataDriver) *DAO

func (*DAO) GetUsers

func (s *DAO) GetUsers() ([]*model.User, error)

func (*DAO) GetUsersByEmail

func (d *DAO) GetUsersByEmail(email string) ([]*model.User, error)

func (*DAO) GetUsersByEmailDomain

func (s *DAO) GetUsersByEmailDomain(domain string) ([]*model.User, error)

type DataDriver

type DataDriver interface {
	Execute(string) error
	Query(string) (*sql.Rows, error)
	QueryPreparedStatement(string, string) (*sql.Rows, error)
	Close() error
}

type DuckDBDriver

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

func NewDuckDBDriver

func NewDuckDBDriver(awsCred aws.AWSCred) *DuckDBDriver

func (*DuckDBDriver) Close

func (d *DuckDBDriver) Close() error

func (*DuckDBDriver) Execute

func (d *DuckDBDriver) Execute(statement string) error

func (*DuckDBDriver) Query

func (d *DuckDBDriver) Query(statement string) (*sql.Rows, error)

func (*DuckDBDriver) QueryPreparedStatement

func (d *DuckDBDriver) QueryPreparedStatement(query string, v string) (*sql.Rows, error)