Documentation
¶
Index ¶
- type PostgreSQL
- func (db *PostgreSQL) CommitTrx() error
- func (db *PostgreSQL) CreateIndexes() error
- func (db *PostgreSQL) CreateOrder(orderId, customerId, warehouseId, districtId, oCarrierId, oOlCnt, allLocal int, ...) error
- func (db *PostgreSQL) CreateSchema() error
- func (db *PostgreSQL) DeleteNewOrder(orderId int, warehouseId int, districtId int) error
- func (db *PostgreSQL) GetCustomer(customerId int, warehouseId int, districtId int) (*models.Customer, error)
- func (db *PostgreSQL) GetCustomerById(customerId int, warehouseId int, districtId int) (*models.Customer, error)
- func (db *PostgreSQL) GetCustomerByName(name string, warehouseId int, districtId int) (*models.Customer, error)
- func (db *PostgreSQL) GetCustomerIdOrder(orderId int, warehouseId int, districtId int) (int, error)
- func (db *PostgreSQL) GetDistrict(warehouseId int, districtId int) (*models.District, error)
- func (db *PostgreSQL) GetItems(itemIds []int) (*[]models.Item, error)
- func (db *PostgreSQL) GetLastOrder(customerId int, warehouseId int, districtId int) (*models.Order, error)
- func (db *PostgreSQL) GetNewOrder(warehouseId int, districtId int) (*models.NewOrder, error)
- func (db *PostgreSQL) GetNextOrderId(warehouseId int, districtId int) (int, error)
- func (db *PostgreSQL) GetOrderLines(orderId int, warehouseId int, districtId int) (*[]models.OrderLine, error)
- func (db *PostgreSQL) GetStockCount(orderIdLt int, orderIdGt int, threshold int, warehouseId int, districtId int) (int64, error)
- func (db *PostgreSQL) GetStockInfo(districtId int, iIds []int, iWids []int, allLocal int) (*[]models.Stock, error)
- func (db *PostgreSQL) GetWarehouse(warehouseId int) (*models.Warehouse, error)
- func (db *PostgreSQL) IncrementDistrictOrderId(warehouseId int, districtId int) error
- func (db *PostgreSQL) InsertBatch(tableName string, d []interface{}) error
- func (db *PostgreSQL) InsertHistory(warehouseId int, districtId int, date time.Time, amount float64, data string) error
- func (db *PostgreSQL) InsertOne(tableName string, d interface{}) error
- func (db *PostgreSQL) RollbackTrx() error
- func (db *PostgreSQL) StartTrx() error
- func (db *PostgreSQL) SumOLAmount(orderId int, warehouseId int, districtId int) (float64, error)
- func (db *PostgreSQL) UpdateCredit(customerId int, warehouseId int, districtId int, balance float64, data string) error
- func (db *PostgreSQL) UpdateCustomer(customerId int, warehouseId int, districtId int, sumOlTotal float64) error
- func (db *PostgreSQL) UpdateDistrictBalance(warehouseId int, districtId int, amount float64) error
- func (db *PostgreSQL) UpdateOrders(orderId int, warehouseId int, districtId int, oCarrierId int, ...) error
- func (db *PostgreSQL) UpdateStock(stockId int, warehouseId int, quantity int, ytd int, ordercnt int, ...) error
- func (db *PostgreSQL) UpdateWarehouseBalance(warehouseId int, amount float64) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PostgreSQL ¶
type PostgreSQL struct {
Client *pgx.Conn
// contains filtered or unexported fields
}
func NewPostgreSQL ¶
func NewPostgreSQL(uri string, dbname string, transactions bool) (*PostgreSQL, error)
func (*PostgreSQL) CommitTrx ¶
func (db *PostgreSQL) CommitTrx() error
func (*PostgreSQL) CreateIndexes ¶
func (db *PostgreSQL) CreateIndexes() error
func (*PostgreSQL) CreateOrder ¶
func (*PostgreSQL) CreateSchema ¶
func (db *PostgreSQL) CreateSchema() error
func (*PostgreSQL) DeleteNewOrder ¶
func (db *PostgreSQL) DeleteNewOrder(orderId int, warehouseId int, districtId int) error
func (*PostgreSQL) GetCustomer ¶
func (*PostgreSQL) GetCustomerById ¶
func (*PostgreSQL) GetCustomerByName ¶
func (*PostgreSQL) GetCustomerIdOrder ¶
func (*PostgreSQL) GetDistrict ¶
func (*PostgreSQL) GetLastOrder ¶
func (*PostgreSQL) GetNewOrder ¶
func (*PostgreSQL) GetNextOrderId ¶
func (db *PostgreSQL) GetNextOrderId(warehouseId int, districtId int) (int, error)
func (*PostgreSQL) GetOrderLines ¶
func (*PostgreSQL) GetStockCount ¶
func (*PostgreSQL) GetStockInfo ¶
func (*PostgreSQL) GetWarehouse ¶
func (db *PostgreSQL) GetWarehouse(warehouseId int) (*models.Warehouse, error)
func (*PostgreSQL) IncrementDistrictOrderId ¶
func (db *PostgreSQL) IncrementDistrictOrderId(warehouseId int, districtId int) error
func (*PostgreSQL) InsertBatch ¶
func (db *PostgreSQL) InsertBatch(tableName string, d []interface{}) error
func (*PostgreSQL) InsertHistory ¶
func (*PostgreSQL) InsertOne ¶
func (db *PostgreSQL) InsertOne(tableName string, d interface{}) error
func (*PostgreSQL) RollbackTrx ¶
func (db *PostgreSQL) RollbackTrx() error
func (*PostgreSQL) StartTrx ¶
func (db *PostgreSQL) StartTrx() error
func (*PostgreSQL) SumOLAmount ¶
func (*PostgreSQL) UpdateCredit ¶
func (*PostgreSQL) UpdateCustomer ¶
func (*PostgreSQL) UpdateDistrictBalance ¶
func (db *PostgreSQL) UpdateDistrictBalance(warehouseId int, districtId int, amount float64) error
func (*PostgreSQL) UpdateOrders ¶
func (*PostgreSQL) UpdateStock ¶
func (*PostgreSQL) UpdateWarehouseBalance ¶
func (db *PostgreSQL) UpdateWarehouseBalance(warehouseId int, amount float64) error
Source Files
Click to show internal directories.
Click to hide internal directories.