sql_db

May 30, 2023

Changes in this version

+ type DbTx struct

+ type SqlDB struct

+ func NewSqlDB(db *sqlx.DB) *SqlDB

+ func (sdb *SqlDB) ExecuteTx(ctx context.Context, callback func(*DbTx) error) (retErr error)

+ func (sdb *SqlDB) GetApprovedFarms(ctx context.Context) ([]types.Farm, error)

+ func (sdb *SqlDB) GetCurrentAcummulatedAmountForAddress(ctx context.Context, address string, farmId int64) (decimal.Decimal, error)

+ func (sdb *SqlDB) GetFarmAuraPoolCollections(ctx context.Context, farmId int64) ([]types.AuraPoolCollection, error)

+ func (sdb *SqlDB) GetLastUTXOTransactionByFarmId(ctx context.Context, farmId int64) (types.UTXOTransaction, error)

+ func (sdb *SqlDB) GetPayoutTimesForNFT(ctx context.Context, collectionDenomId string, nftId string) ([]types.NFTStatistics, error)

+ func (sdb *SqlDB) GetTxHashesByStatus(ctx context.Context, status string) ([]types.TransactionHashWithStatus, error)

+ func (sdb *SqlDB) GetUTXOTransaction(ctx context.Context, txHash string) (types.UTXOTransaction, error)

+ func (sdb *SqlDB) SaveRBFTransactionInformation(ctx context.Context, ...) error

+ func (sdb *SqlDB) SaveStatistics(ctx context.Context, receivedRewardForFarmBtcDecimal decimal.Decimal, ...) (retErr error)

+ func (sdb *SqlDB) SaveTxHashWithStatus(ctx context.Context, txHash, txStatus, farmSubAccountName string, ...) error

+ func (sdb *SqlDB) SetInitialAccumulatedAmountForAddress(ctx context.Context, address string, farmId int64, amount int) error

+ func (sdb *SqlDB) UpdateThresholdStatus(ctx context.Context, processedTransaction string, paymentTimestamp int64, ...) (retErr error)

+ func (sdb *SqlDB) UpdateTransactionsStatus(ctx context.Context, txHashes []string, txStatus string) error

+ type SqlExecutor interface

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)