sqlengine

type SQLEngine interface {
	GetDB() (*sql.DB, error)
	GetTx() (*sql.Tx, error)
	Exec(string, ...interface{}) (sql.Result, error)
	Query(string, ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...any) *sql.Row
	ExecFileLocal(string) error
	ExecFile(string) error
	ExecInTxn(queries []string) error
	GetCurrentGenerationID() (int, error)
	GetNextGenerationID() (int, error)
	GetCurrentSessionID(int) (int, error)
	GetNextSessionID(int) (int, error)
	GetCurrentDiscoveryGenerationID(discoveryID string) (int, error)
	GetNextDiscoveryGenerationID(discoveryID string) (int, error)
	CacheStoreGet(string) ([]byte, error)
	CacheStoreGetAll() ([]internaldto.KeyVal, error)
	CacheStorePut(string, []byte, string, int) error
	IsMemory() bool
}