Package storage

Class MongoDBStorage

java.lang.Object

storage.AbstractDataStorage

storage.MongoDBStorage

All Implemented Interfaces:

DataStorage

public class MongoDBStorage
extends AbstractDataStorage

Field Summary

Fields

Modifier and Type	Field	Description
private com.mongodb.client.MongoCollection<org.bson.Document>	accounts
private com.mongodb.client.MongoCollection<org.bson.Document>	branches
private com.mongodb.client.MongoCollection<org.bson.Document>	customerAccounts
private com.mongodb.client.MongoCollection<org.bson.Document>	customers
private com.mongodb.client.MongoDatabase	database
private com.mongodb.client.MongoCollection<org.bson.Document>	employees
private com.mongodb.client.MongoClient	mongoClient
private com.mongodb.client.MongoCollection<org.bson.Document>	userSalts

Constructor Summary

Constructors

Constructor	Description
MongoDBStorage()

Method Summary

Modifier and Type	Method	Description
int	addCustomerToAccount(int customerId, int accountNo, String role)	Adds a customer to an existing account as joint holder.
void	clearAllCollections()
void	close()
private org.bson.Document	createDocumentWithId(int id, org.bson.Document doc)
boolean	deleteAccount(int accountNo)	Deletes an account by account number.
boolean	deleteCustomer(int customerId)	Deletes a customer by ID.
boolean	depositToAccount(int accountNo, BigDecimal amount)	Deposits money to an account.
SavingsAccount	getAccount(int accountNo)	Retrieves an account by account number.
List<SavingsAccount>	getAccountsByBranch(int branchId)	Gets all accounts for a specific branch.
List<SavingsAccount>	getAccountsByCustomer(int customerId)
Branch	getBranch(int branchId)	Retrieves a branch by ID.
Customer	getCustomer(int customerId)	Retrieves a customer by ID.
Customer	getCustomerByEmail(String email)	Retrieves a customer by email address.
List<Customer>	getCustomersByAccount(int accountNo)	Gets all customers who are holders of an account.
List<Customer>	getCustomersByBranch(int branchId)	Gets all customers for a specific branch.
Employee	getEmployee(int employeeId)	Retrieves an employee by ID.
Employee	getEmployeeByEmail(String email)	Retrieves an employee by email address.
private int	getIdAsInteger(org.bson.Document doc)
Manager	getManager(int employeeId)
String	getSaltForCustomer(int customerId)	Gets the password salt for a customer.
String	getSaltForEmployee(int employeeId)
boolean	removeCustomerFromAccount(int customerId, int accountNo)	Removes a customer from a joint account.
int	saveAccount(SavingsAccount account)	Saves a new account to storage.
void	saveBranch(Branch branch)	Saves a branch to storage.
int	saveCustomer(Customer customer)	Saves a new customer to storage.
int	saveCustomerWithPassword(Customer customer, String salt)	Saves a new customer with password for login capability.
int	saveEmployee(Employee employee)	Saves a new employee to storage.
int	saveEmployeeWithPassword(Employee employee, String salt)	Saves a new employee with password for login capability.
void	updateAccount(SavingsAccount account)	Updates an existing account.
void	updateCustomer(Customer customer)	Updates an existing customer's information.
boolean	withdrawFromAccount(int accountNo, BigDecimal amount)	Withdraws money from an account.

Methods inherited from class storage.AbstractDataStorage

isValidEmail

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface storage.DataStorage

getTransactionHistory, getTransactionHistory, getTransactionHistoryByDateRange, logTransaction

Field Details

mongoClient

private com.mongodb.client.MongoClient mongoClient

database

private com.mongodb.client.MongoDatabase database

customers

private com.mongodb.client.MongoCollection<org.bson.Document> customers

employees

private com.mongodb.client.MongoCollection<org.bson.Document> employees

accounts

private com.mongodb.client.MongoCollection<org.bson.Document> accounts

branches

private com.mongodb.client.MongoCollection<org.bson.Document> branches

customerAccounts

private com.mongodb.client.MongoCollection<org.bson.Document> customerAccounts

userSalts

private com.mongodb.client.MongoCollection<org.bson.Document> userSalts

Constructor Details

MongoDBStorage

public MongoDBStorage()

Method Details

getIdAsInteger

private int getIdAsInteger(org.bson.Document doc)

createDocumentWithId

private org.bson.Document createDocumentWithId(int id,
 org.bson.Document doc)

saveCustomer

public int saveCustomer(Customer customer)

Saves a new customer to storage.

Specified by:

saveCustomer in interface DataStorage

Specified by:

saveCustomer in class AbstractDataStorage

Parameters:

customer - the customer to save

Returns:

the generated customer ID

saveCustomerWithPassword

public int saveCustomerWithPassword(Customer customer,
 String salt)

Saves a new customer with password for login capability.

Specified by:

saveCustomerWithPassword in interface DataStorage

Specified by:

saveCustomerWithPassword in class AbstractDataStorage

Parameters:

customer - the customer to save

salt - the password salt for security

Returns:

the generated customer ID

getCustomer

public Customer getCustomer(int customerId)

Retrieves a customer by ID.

Specified by:

getCustomer in interface DataStorage

Specified by:

getCustomer in class AbstractDataStorage

Parameters:

customerId - the customer ID

Returns:

the customer or null if not found

getCustomerByEmail

public Customer getCustomerByEmail(String email)

Retrieves a customer by email address.

Specified by:

getCustomerByEmail in interface DataStorage

Specified by:

getCustomerByEmail in class AbstractDataStorage

Parameters:

email - the customer's email

Returns:

the customer or null if not found

updateCustomer

public void updateCustomer(Customer customer)
                    throws SQLException

Updates an existing customer's information.

Specified by:

updateCustomer in interface DataStorage

Specified by:

updateCustomer in class AbstractDataStorage

Parameters:

customer - the customer to update

Throws:

SQLException - if database operation fails

deleteCustomer

public boolean deleteCustomer(int customerId)

Deletes a customer by ID.

Specified by:

deleteCustomer in interface DataStorage

Specified by:

deleteCustomer in class AbstractDataStorage

Parameters:

customerId - the customer ID to delete

Returns:

true if deletion was successful, false otherwise

getCustomersByBranch

public List<Customer> getCustomersByBranch(int branchId)

Gets all customers for a specific branch.

Specified by:

getCustomersByBranch in interface DataStorage

Specified by:

getCustomersByBranch in class AbstractDataStorage

Parameters:

branchId - the branch ID

Returns:

list of customers in the branch

getSaltForCustomer

public String getSaltForCustomer(int customerId)

Gets the password salt for a customer.

Specified by:

getSaltForCustomer in interface DataStorage

Specified by:

getSaltForCustomer in class AbstractDataStorage

Parameters:

customerId - the customer ID

Returns:

the password salt or null if not found

saveEmployee

public int saveEmployee(Employee employee)

Saves a new employee to storage.

Specified by:

saveEmployee in interface DataStorage

Specified by:

saveEmployee in class AbstractDataStorage

Parameters:

employee - the employee to save

Returns:

the generated employee ID

saveEmployeeWithPassword

public int saveEmployeeWithPassword(Employee employee,
 String salt)

Saves a new employee with password for login capability.

Specified by:

saveEmployeeWithPassword in interface DataStorage

Specified by:

saveEmployeeWithPassword in class AbstractDataStorage

Parameters:

employee - the employee to save

salt - the password salt for security

Returns:

the generated employee ID

getEmployee

public Employee getEmployee(int employeeId)

Retrieves an employee by ID.

Specified by:

getEmployee in interface DataStorage

Specified by:

getEmployee in class AbstractDataStorage

Parameters:

employeeId - the employee ID

Returns:

the employee or null if not found

getEmployeeByEmail

public Employee getEmployeeByEmail(String email)

Retrieves an employee by email address.

Specified by:

getEmployeeByEmail in interface DataStorage

Specified by:

getEmployeeByEmail in class AbstractDataStorage

Parameters:

email - the employee's email

Returns:

the employee or null if not found

getManager

public Manager getManager(int employeeId)

Specified by:

getManager in interface DataStorage

Specified by:

getManager in class AbstractDataStorage

getSaltForEmployee

public String getSaltForEmployee(int employeeId)

Specified by:

getSaltForEmployee in interface DataStorage

Specified by:

getSaltForEmployee in class AbstractDataStorage

saveAccount

public int saveAccount(SavingsAccount account)

Saves a new account to storage.

Specified by:

saveAccount in interface DataStorage

Specified by:

saveAccount in class AbstractDataStorage

Parameters:

account - the account to save

Returns:

the generated account number

getAccount

public SavingsAccount getAccount(int accountNo)

Retrieves an account by account number.

Specified by:

getAccount in interface DataStorage

Specified by:

getAccount in class AbstractDataStorage

Parameters:

accountNo - the account number

Returns:

the account or null if not found

updateAccount

public void updateAccount(SavingsAccount account)

Updates an existing account.

Specified by:

updateAccount in interface DataStorage

Specified by:

updateAccount in class AbstractDataStorage

Parameters:

account - the account to update

deleteAccount

public boolean deleteAccount(int accountNo)

Deletes an account by account number.

Specified by:

deleteAccount in interface DataStorage

Specified by:

deleteAccount in class AbstractDataStorage

Parameters:

accountNo - the account number to delete

Returns:

true if deletion was successful, false otherwise

getAccountsByBranch

public List<SavingsAccount> getAccountsByBranch(int branchId)

Gets all accounts for a specific branch.

Specified by:

getAccountsByBranch in interface DataStorage

Specified by:

getAccountsByBranch in class AbstractDataStorage

Parameters:

branchId - the branch ID

Returns:

list of accounts in the branch

getAccountsByCustomer

public List<SavingsAccount> getAccountsByCustomer(int customerId)

Specified by:

getAccountsByCustomer in interface DataStorage

Specified by:

getAccountsByCustomer in class AbstractDataStorage

withdrawFromAccount

public boolean withdrawFromAccount(int accountNo,
 BigDecimal amount)

Withdraws money from an account.

Specified by:

withdrawFromAccount in interface DataStorage

Specified by:

withdrawFromAccount in class AbstractDataStorage

Parameters:

accountNo - the account number

amount - the amount to withdraw

Returns:

true if withdrawal was successful, false otherwise

depositToAccount

public boolean depositToAccount(int accountNo,
 BigDecimal amount)

Deposits money to an account.

Specified by:

depositToAccount in interface DataStorage

Specified by:

depositToAccount in class AbstractDataStorage

Parameters:

accountNo - the account number

amount - the amount to deposit

Returns:

true if deposit was successful, false otherwise

saveBranch

public void saveBranch(Branch branch)

Saves a branch to storage.

Specified by:

saveBranch in interface DataStorage

Specified by:

saveBranch in class AbstractDataStorage

Parameters:

branch - the branch to save

getBranch

public Branch getBranch(int branchId)

Retrieves a branch by ID.

Specified by:

getBranch in interface DataStorage

Specified by:

getBranch in class AbstractDataStorage

Parameters:

branchId - the branch ID

Returns:

the branch or null if not found

addCustomerToAccount

public int addCustomerToAccount(int customerId,
 int accountNo,
 String role)

Adds a customer to an existing account as joint holder. Default implementation throws UnsupportedOperationException.

Parameters:

customerId - the customer ID to add

accountNo - the account number

role - the customer's role (PRIMARY, JOINT)

Returns:

the result status

Throws:

UnsupportedOperationException - if not supported by implementation

removeCustomerFromAccount

public boolean removeCustomerFromAccount(int customerId,
 int accountNo)

Removes a customer from a joint account. Default implementation throws UnsupportedOperationException.

Parameters:

customerId - the customer ID to remove

accountNo - the account number

Returns:

true if removal was successful, false otherwise

Throws:

UnsupportedOperationException - if not supported by implementation

getCustomersByAccount

public List<Customer> getCustomersByAccount(int accountNo)

Gets all customers who are holders of an account. Default implementation throws UnsupportedOperationException.

Parameters:

accountNo - the account number

Returns:

list of account holders

Throws:

UnsupportedOperationException - if not supported by implementation

clearAllCollections

public void clearAllCollections()

close

public void close()