orderRoDataStore

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type GetOrderByIdNewRow struct {
	OrderID  string `json:"order_id"`
	OrderQty int32  `json:"order_qty"`
}

type MySqlConfig struct {
	Database             string `yaml:"database"`
	Host                 string `yaml:"host"`
	Port                 int    `yaml:"port"`
	User                 string `yaml:"user"`
	Password             string `yaml:"password"`
	MaxIdleConnection    int    `yaml:"max_idle_connections"`
	MaxOpenConnection    int    `yaml:"max_open_connections"`
	ConnMaxLifetimeInSec int    `yaml:"connection_max_lifetime_sec"`
	ConnMaxIdleTimeInSec int    `yaml:"connection_max_idle_time_sec"`
}

type Order struct {
	OrderID   string       `json:"order_id"`
	OrderQty  int32        `json:"order_qty"`
	Amount    string       `json:"amount"`
	CreatedAt sql.NullTime `json:"created_at"`
	UpdatedAt sql.NullTime `json:"updated_at"`
}

type Querier interface {
	//GetAllOrders
	//
	//  SELECT order_id, order_qty, amount, created_at, updated_at
	//  FROM orders
	//  ORDER BY created_at DESC
	GetAllOrders(ctx context.Context) ([]*Order, error)
	//GetOrderByID
	//
	//  SELECT order_id, order_qty, amount, created_at, updated_at
	//  FROM orders
	//  WHERE order_id = ?
	GetOrderByID(ctx context.Context, orderID string) (*Order, error)
	//GetOrderByIdNew
	//
	//  SELECT order_id, order_qty
	//  FROM orders
	//  WHERE order_id = ?
	GetOrderByIdNew(ctx context.Context, orderID string) (*GetOrderByIdNewRow, error)
}

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