Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

databases

package

Go to main page

Versions in this module

v0

v0.0.3

Oct 6, 2020

v0.0.2

Oct 6, 2020

Changes in this version

type Database

+ func NewMongoDb(uri string, dbname string, transactions bool, findandmodify bool) (*Database, error)

+ func (db *Database) CommitTrx() error

+ func (db *Database) CreateOrder(orderId int, customerId int, warehouseId int, districtId int, oCarrierId int, ...) error

+ func (db *Database) DeleteNewOrder(orderId int, warehouseId int, districtId int) error

+ func (db *Database) GetCustomer(customerId int, warehouseId int, districtId int) (*models.Customer, error)

+ func (db *Database) GetCustomerById(customerId int, warehouseId int, districtId int) (*models.Customer, error)

+ func (db *Database) GetCustomerByName(name string, warehouseId int, districtId int) (*models.Customer, error)

+ func (db *Database) GetCustomerIdOrder(orderId int, warehouseId int, districtId int) (int, error)

+ func (db *Database) GetDistrict(warehouseId int, districtId int) (*models.District, error)

+ func (db *Database) GetItems(itemIds []int) (*[]models.Item, error)

+ func (db *Database) GetLastOrder(customerId int, warehouseId int, districtId int) (*models.Order, error)

+ func (db *Database) GetNewOrder(warehouseId int, districtId int) (*models.NewOrder, error)

+ func (db *Database) GetNextOrderId(warehouseId int, districtId int) (int, error)

+ func (db *Database) GetOrderLines(orderId int, warehouseId int, districtId int) (*[]models.OrderLine, error)

+ func (db *Database) GetStockCount(orderIdLt int, orderIdGt int, threshold int, warehouseId int, districtId int) (int64, error)

+ func (db *Database) GetStockInfo(districtId int, iIds []int, iWids []int, allLocal int) (*[]models.Stock, error)

+ func (db *Database) GetWarehouse(warehouseId int) (*models.Warehouse, error)

+ func (db *Database) IncrementDistrictOrderId(warehouseId int, districtId int) error

+ func (db *Database) InsertHistory(warehouseId int, districtId int, date time.Time, amount float64, data string) error

+ func (db *Database) RollbackTrx() error

+ func (db *Database) StartTrx() error

+ func (db *Database) UpdateCredit(customerId int, warehouseId int, districtId int, balance float64, data string) error

+ func (db *Database) UpdateCustomer(customerId int, warehouseId int, districtId int, sumOlTotal float64) error

+ func (db *Database) UpdateDistrictBalance(warehouseId int, districtId int, amount float64) error

+ func (db *Database) UpdateOrders(orderId int, warehouseId int, districtId int, oCarrierId int, ...) error

+ func (db *Database) UpdateStock(stockId int, warehouseId int, quantity int, ytd int, ordercnt int, ...) error

+ func (db *Database) UpdateWarehouseBalance(warehouseId int, amount float64) error

v0.0.1

Sep 30, 2020

Changes in this version

+ type Database struct

+ Aggregate bool

+ C *mongo.Database

+ Client *mongo.Client

+ func NewDb(uri string, dbname string, transactions bool, findandmodify bool) (*Database, error)

+ func (db *Database) CreateIndexes() error

+ func (db *Database) DoDelivery(ctx context.Context, wId int, oCarrierId int, olDeliveryD time.Time, dId int) error

+ func (db *Database) DoNewOrder(ctx context.Context, w_id int, d_id int, c_id int, o_entry_d time.Time, ...) error

+ func (db *Database) DoOrderStatus(ctx context.Context, wId int, dId int, cId int, cLast string) error

+ func (db *Database) DoPayment(ctx context.Context, wId int, dId int, hAmount float64, cWId int, cDId int, ...) error

+ func (db *Database) DoStockLevelTrx(ctx context.Context, wId int, dId int, threshold int) error

+ func (db *Database) DoTrxRetries(fn func(ctx context.Context) error, retries int) error

+ func (db *Database) InsertBatch(collectionName string, d []interface{}) error

+ func (db *Database) InsertOne(collectionName string, d interface{}) error