2martens/dis
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Added first version of persistence

Browse Source 
Signed-off-by: Jim Martens <github@2martens.de>
This commit is contained in:
Jim Martens
2017-05-19 13:03:26 +02:00
parent 3ea966dcc9
commit 90d537f64d
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
04/src/PersistenceManager.java
View File

@ -134,7 +134,6 @@ public class PersistenceManager {
return; return;
} }
// TODO persist the data of committed transactions
Enumeration<Integer> transactionIDs = _transactions.keys(); Enumeration<Integer> transactionIDs = _transactions.keys();
List<Integer> commitedTransactions = new ArrayList<>(); List<Integer> commitedTransactions = new ArrayList<>();
while (transactionIDs.hasMoreElements()) { while (transactionIDs.hasMoreElements()) {
@ -145,11 +144,19 @@ public class PersistenceManager {
} }
} }
// TODO update log file as needed
for (int taid : commitedTransactions) { for (int taid : commitedTransactions) {
// TODO persist data of committed transaction
Set<Integer> pageIDs = _transactionPageBuffer.get(taid); Set<Integer> pageIDs = _transactionPageBuffer.get(taid);
for (int pageid : pageIDs) { for (int pageid : pageIDs) {
// TODO persist data of pageID int lsn = _pageLSN.get(pageid);
try {
FileWriter fw = new FileWriter("../data/" + pageid + ".txt", false);
fw.write(pageid + "," + lsn + "," + _pageBuffer.get(pageid));
fw.close();
} catch (IOException e) {
e.printStackTrace();
}
_pageLSN.remove(pageid);
_pageBuffer.remove(pageid); _pageBuffer.remove(pageid);
} }
_transactionPageBuffer.remove(taid); _transactionPageBuffer.remove(taid);