mysqldb

Documentation

Index

• func ValidateConnectionString(dsn string) (string, error)
• type Database
  • func NewDB(connection_string string) (*Database, error)
  • func (db *Database) AddAccount(acc *core.Account) error
  • func (db *Database) AddCurrency(cur *core.Currency) error
  • func (db *Database) AddTag(tag string) error
  • func (db *Database) AddTagToAccount(accountID string, tag int) error
  • func (db *Database) AddTagToTransaction(txnID string, tag int) error
  • func (db *Database) AddTransaction(txn *core.Transaction) (string, error)
  • func (db *Database) AddUser(usr *core.User) error
  • func (db *Database) ClearDB() error
  • func (db *Database) Close() error
  • func (db *Database) DeleteAccount(account string) error
  • func (db *Database) DeleteCurrency(currency string) error
  • func (db *Database) DeleteTagFromAccount(account, tag string) error
  • func (db *Database) DeleteTagFromTransaction(txnID, tag string) error
  • func (db *Database) DeleteTransaction(txnID string) error
  • func (db *Database) FindAccount(code string) (*core.Account, error)
  • func (db *Database) FindCurrency(cur string) (*core.Currency, error)
  • func (db *Database) FindTag(tag string) (int, error)
  • func (db *Database) FindTransaction(txnID string) (*core.Transaction, error)
  • func (db *Database) FindUser(pubKey string) (*core.User, error)
  • func (db *Database) GetListing(startDate, endDate time.Time) (*[]core.Transaction, error)
  • func (db *Database) GetTB(queryDate time.Time) (*[]core.TBAccount, error)
  • func (db *Database) InitDB() error
  • func (db *Database) Query(query string, args ...interface{}) (*sql.Rows, error)
  • func (db *Database) ReconcileTransactions(reconciliationID string, splitIDs []string) (string, error)
  • func (db *Database) SafeAddAccount(acc *core.Account) (bool, error)
  • func (db *Database) SafeAddCurrency(cur *core.Currency) error
  • func (db *Database) SafeAddTag(tag string) error
  • func (db *Database) SafeAddTagToAccount(account, tag string) error
  • func (db *Database) SafeAddTagToTransaction(txnID, tag string) error
  • func (db *Database) SafeAddUser(usr *core.User) error
  • func (db *Database) TestDB() error

Functions

func ValidateConnectionString

func ValidateConnectionString(dsn string) (string, error)

Types

type Database

type Database struct {
	DB               *sql.DB
	ConnectionString string
}

func NewDB

func NewDB(connection_string string) (*Database, error)

NewDB initializes a new DB.

func (*Database) AddAccount

func (db *Database) AddAccount(acc *core.Account) error

func (*Database) AddCurrency

func (db *Database) AddCurrency(cur *core.Currency) error

func (*Database) AddTag

func (db *Database) AddTag(tag string) error

func (*Database) AddTagToAccount

func (db *Database) AddTagToAccount(accountID string, tag int) error

func (*Database) AddTagToTransaction

func (db *Database) AddTagToTransaction(txnID string, tag int) error

func (*Database) AddTransaction

func (db *Database) AddTransaction(txn *core.Transaction) (string, error)

func (*Database) AddUser

func (db *Database) AddUser(usr *core.User) error

func (*Database) ClearDB

func (db *Database) ClearDB() error

ClearDB drops all tables

func (*Database) Close

func (db *Database) Close() error

Close closes the underlying database.

func (*Database) DeleteAccount

func (db *Database) DeleteAccount(account string) error

func (*Database) DeleteCurrency

func (db *Database) DeleteCurrency(currency string) error

func (*Database) DeleteTagFromAccount

func (db *Database) DeleteTagFromAccount(account, tag string) error

func (*Database) DeleteTagFromTransaction

func (db *Database) DeleteTagFromTransaction(txnID, tag string) error

func (*Database) DeleteTransaction

func (db *Database) DeleteTransaction(txnID string) error

func (*Database) FindAccount

func (db *Database) FindAccount(code string) (*core.Account, error)

func (*Database) FindCurrency

func (db *Database) FindCurrency(cur string) (*core.Currency, error)

func (*Database) FindTag

func (db *Database) FindTag(tag string) (int, error)

func (*Database) FindTransaction

func (db *Database) FindTransaction(txnID string) (*core.Transaction, error)

func (*Database) FindUser

func (db *Database) FindUser(pubKey string) (*core.User, error)

func (*Database) GetListing

func (db *Database) GetListing(startDate, endDate time.Time) (*[]core.Transaction, error)

func (*Database) GetTB

func (db *Database) GetTB(queryDate time.Time) (*[]core.TBAccount, error)

func (*Database) InitDB

func (db *Database) InitDB() error

func (*Database) Query

func (db *Database) Query(query string, args ...interface{}) (*sql.Rows, error)

func (*Database) ReconcileTransactions

func (db *Database) ReconcileTransactions(reconciliationID string, splitIDs []string) (string, error)

func (*Database) SafeAddAccount

func (db *Database) SafeAddAccount(acc *core.Account) (bool, error)

func (*Database) SafeAddCurrency

func (db *Database) SafeAddCurrency(cur *core.Currency) error

func (*Database) SafeAddTag

func (db *Database) SafeAddTag(tag string) error

func (*Database) SafeAddTagToAccount

func (db *Database) SafeAddTagToAccount(account, tag string) error

func (*Database) SafeAddTagToTransaction

func (db *Database) SafeAddTagToTransaction(txnID, tag string) error

func (*Database) SafeAddUser

func (db *Database) SafeAddUser(usr *core.User) error

func (*Database) TestDB

func (db *Database) TestDB() error