TransactionDao

Added basic transaction Dao for database

src/main/java/database/transaction/TransactionDao.java

@@ -0,0 +1,56 @@
+package database.transaction;
+
+import com.j256.ormlite.dao.Dao;
+import com.j256.ormlite.dao.DaoManager;
+import com.j256.ormlite.stmt.PreparedQuery;
+import com.j256.ormlite.stmt.QueryBuilder;
+import database.DatabaseHelper;
+
+import java.util.List;
+
+public class TransactionDao {
+    private DatabaseHelper dbh = new DatabaseHelper();
+    private Dao<Transaction, String> transactionDao;
+
+    private Dao createTransactionDaoConnection(){
+        try {
+            return DaoManager.createDao(dbh.setupDatabaseConnection(),Transaction.class);
+        }catch (Exception e){
+            System.out.println(e.getMessage());
+            return null;
+        }
+    }
+
+    public void addTransaction(Transaction transaction)throws Exception{
+        transactionDao = createTransactionDaoConnection();
+        transactionDao.create(transaction);
+    }
+
+    public List<Transaction> getUserTransactions(int userId)throws Exception{
+        transactionDao = createTransactionDaoConnection();
+        QueryBuilder<Transaction, String> queryBuilder = transactionDao.queryBuilder();
+        queryBuilder.where().eq("userId",userId);
+        PreparedQuery<Transaction> preparedQuery = queryBuilder.prepare();
+        return transactionDao.query(preparedQuery);
+    }
+
+    public List<Transaction> getTenLastUserTransactions(int userId)throws Exception{
+        transactionDao = createTransactionDaoConnection();
+        QueryBuilder<Transaction, String> queryBuilder = transactionDao.queryBuilder();
+        queryBuilder.where().eq("userId",userId);
+        queryBuilder.limit(new Long(10));
+        queryBuilder.orderBy("transactionDate",false);
+        PreparedQuery<Transaction> preparedQuery = queryBuilder.prepare();
+        return transactionDao.query(preparedQuery);
+    }
+
+    public Transaction getTransaction(int userId, String transactionHash)throws Exception{
+        transactionDao = createTransactionDaoConnection();
+        QueryBuilder<Transaction, String> queryBuilder = transactionDao.queryBuilder();
+        queryBuilder.where().eq("userId",userId).and().eq("transactionHash",transactionHash);
+        PreparedQuery<Transaction> preparedQuery = queryBuilder.prepare();
+        return transactionDao.queryForFirst(preparedQuery);
+    }
+
+
+}

src/main/java/database/user/UserDao.java

@@ -107,6 +107,7 @@ public class UserDao {
         updateBuilder.where().eq("email",email);
         updateBuilder.update();
     }
+
     public void verifyUser (String email) throws Exception{
         userDao = createUserDaoConnection();
         UpdateBuilder<User, String> updateBuilder = userDao.updateBuilder();