db_connect

package

v0.0.0-...-13a5213 Latest Latest Go to latest Published: Oct 13, 2024 License: Unlicense Imports: 7 Imported by: 0

Documentation ¶

Index ¶

func AddOperation(ctx context.Context, db SQLQueryExec, value *entities.Operation) (int, error)
func AgentPing(ctx context.Context, db SQLQueryExec, id int, status, statusText string) int
func CreateExpression(ctx context.Context, db SQLQueryExec, expression entities.Expression) (int, error)
func CreateOperationsTime(ctx context.Context, db SQLQueryExec) (int, error)
func CreateUser(ctx context.Context, db SQLQueryExec, user entities.User) (int, error)
func DeleteAgent(ctx context.Context, db SQLQueryExec, id int) error
func DeleteOperation(ctx context.Context, db SQLQueryExec, id int) error
func GetAllAgents(ctx context.Context, db SQLQueryExec) ([]entities.Agent, error)
func GetAllExpressions(ctx context.Context, db SQLQueryExec) ([]entities.Expression, error)
func GetAllOperations(ctx context.Context, db SQLQueryExec) ([]entities.Operation, error)
func GetExpressionByID(ctx context.Context, db SQLQueryExec, id int) (entities.Expression, error)
func GetOperationByID(ctx context.Context, db SQLQueryExec, id int) (entities.Operation, error)
func GetOperationsTimeByID(ctx context.Context, db SQLQueryExec, id int) (entities.OperationsTime, error)
func GetOperationsTimeByUserID(ctx context.Context, db SQLQueryExec, id int) (entities.OperationsTime, error)
func GetReadyToExecuteOperations(ctx context.Context, db SQLQueryExec) ([]entities.IdSoup, error)
func GetUserByID(ctx context.Context, db SQLQueryExec, id int) (entities.User, error)
func GetUserByName(ctx context.Context, db SQLQueryExec, name string) (entities.User, error)
func IsReadyToExecuteOperation(ctx context.Context, db SQLQueryExec, id int) (bool, error)
func OhNoExpressionError(ctx context.Context, db SQLQueryExec, id int)
func OpenDb(ctx context.Context, connectionString string) (*sql.DB, error)
func UpdateExpression(ctx context.Context, db SQLQueryExec, id int, newResult float64, status string) error
func UpdateFatherOperation(ctx context.Context, db SQLQueryExec, id, fatherId, side int) error
func UpdateLeftOperation(ctx context.Context, db SQLQueryExec, id int, leftData float64) error
func UpdateOperationsTimeByID(ctx context.Context, db SQLQueryExec, operationsTimes entities.OperationsTime, ...) error
func UpdateOperationsTimeByUserID(ctx context.Context, db SQLQueryExec, operationsTimes entities.OperationsTime, ...) error
func UpdateRightOperation(ctx context.Context, db SQLQueryExec, id int, rightData float64) error
type SQLQueryExec
type SQLTXQueryExec

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddOperation ¶

func AddOperation(ctx context.Context, db SQLQueryExec, value *entities.Operation) (int, error)

func AgentPing ¶

func AgentPing(ctx context.Context, db SQLQueryExec, id int, status, statusText string) int

func CreateExpression ¶

func CreateExpression(ctx context.Context, db SQLQueryExec, expression entities.Expression) (int, error)

func CreateOperationsTime ¶

func CreateOperationsTime(ctx context.Context, db SQLQueryExec) (int, error)

func CreateUser ¶

func CreateUser(ctx context.Context, db SQLQueryExec, user entities.User) (int, error)

func DeleteAgent ¶

func DeleteAgent(ctx context.Context, db SQLQueryExec, id int) error

func DeleteOperation ¶

func DeleteOperation(ctx context.Context, db SQLQueryExec, id int) error

func GetAllAgents ¶

func GetAllAgents(ctx context.Context, db SQLQueryExec) ([]entities.Agent, error)

func GetAllExpressions ¶

func GetAllExpressions(ctx context.Context, db SQLQueryExec) ([]entities.Expression, error)

func GetAllOperations ¶

func GetAllOperations(ctx context.Context, db SQLQueryExec) ([]entities.Operation, error)

func GetExpressionByID ¶

func GetExpressionByID(ctx context.Context, db SQLQueryExec, id int) (entities.Expression, error)

func GetOperationByID ¶

func GetOperationByID(ctx context.Context, db SQLQueryExec, id int) (entities.Operation, error)

func GetOperationsTimeByID ¶

func GetOperationsTimeByID(ctx context.Context, db SQLQueryExec, id int) (entities.OperationsTime, error)

func GetOperationsTimeByUserID ¶

func GetOperationsTimeByUserID(ctx context.Context, db SQLQueryExec, id int) (entities.OperationsTime, error)

func GetReadyToExecuteOperations ¶

func GetReadyToExecuteOperations(ctx context.Context, db SQLQueryExec) ([]entities.IdSoup, error)

func GetUserByID ¶

func GetUserByID(ctx context.Context, db SQLQueryExec, id int) (entities.User, error)

func GetUserByName ¶

func GetUserByName(ctx context.Context, db SQLQueryExec, name string) (entities.User, error)

func IsReadyToExecuteOperation ¶

func IsReadyToExecuteOperation(ctx context.Context, db SQLQueryExec, id int) (bool, error)

func OhNoExpressionError ¶

func OhNoExpressionError(ctx context.Context, db SQLQueryExec, id int)

func OpenDb ¶

func OpenDb(ctx context.Context, connectionString string) (*sql.DB, error)

func UpdateExpression ¶

func UpdateExpression(ctx context.Context, db SQLQueryExec, id int, newResult float64, status string) error

func UpdateFatherOperation ¶

func UpdateFatherOperation(ctx context.Context, db SQLQueryExec, id, fatherId, side int) error

func UpdateLeftOperation ¶

func UpdateLeftOperation(ctx context.Context, db SQLQueryExec, id int, leftData float64) error

func UpdateOperationsTimeByID ¶

func UpdateOperationsTimeByID(ctx context.Context, db SQLQueryExec, operationsTimes entities.OperationsTime, id int) error

func UpdateOperationsTimeByUserID ¶

func UpdateOperationsTimeByUserID(ctx context.Context, db SQLQueryExec, operationsTimes entities.OperationsTime, userId int) error

func UpdateRightOperation ¶

func UpdateRightOperation(ctx context.Context, db SQLQueryExec, id int, rightData float64) error

Types ¶

type SQLQueryExec ¶

type SQLQueryExec interface {
	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row

	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type SQLTXQueryExec ¶

type SQLTXQueryExec interface {
	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

	Exec(query string, args ...any) (sql.Result, error)
	Query(query string, args ...any) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row

	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL