Function TestCreateAccount_QueryError

database/account_test.go:180–207

(t *testing.T)

}

func TestCreateAccount_QueryError(t *testing.T) {
	db, mock, err := sqlmock.New()
	assert.NoError(t, err)
	defer func() { _ = db.Close() }()

	ds := Datasource{Conn: db}

	account := model.Account{
		Name:       "Test Account",
		Number:     "1234567890",
		BankName:   "Test Bank",
		Currency:   "USD",
		LedgerID:   "ldg1",
		IdentityID: "idt1",
		BalanceID:  "bal1",
		MetaData:   map[string]interface{}{},
	}

	metaDataJSON, err := json.Marshal(account.MetaData)
	assert.NoError(t, err)

	mock.ExpectExec("INSERT INTO ledgerforge.accounts").
		WithArgs(sqlmock.AnyArg(), account.Name, account.Number, account.BankName, account.Currency, account.LedgerID, account.IdentityID, account.BalanceID, sqlmock.AnyArg(), metaDataJSON).
		WillReturnError(fmt.Errorf("database connection error"))

	_, err = ds.CreateAccount(account)
	assert.Error(t, err)
}

func TestGetAccountByID_NotFound(t *testing.T) {
	db, mock, err := sqlmock.New()