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

Implementation of persist(Contract)

Browse Source 
Added the implementaion of persist(Contract)
Changed 2 types of variables of TenancyContract to Timestamp
Updated Interface for Timestamp input
This commit is contained in:
Togepy95
2017-04-22 13:13:04 +02:00
parent 5151567386
commit 82c8df3e5c
3 changed files with 115 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
02/src/de/dis2017/Main.java
View File

@ -11,6 +11,7 @@ import de.dis2017.data.TenancyContract;
import de.dis2017.data.db.ORM; import de.dis2017.data.db.ORM;
import de.dis2017.data.db.Type; import de.dis2017.data.db.Type;
import java.sql.Timestamp;
import java.util.List; import java.util.List;
/** /**
@ -146,18 +147,22 @@ public class Main {
contract.setDate(FormUtil.readString("Date")); contract.setDate(FormUtil.readString("Date"));
if(_orm.isApartment(contract.getEstate())){ if(_orm.isApartment(contract.getEstate())){
TenancyContract tenContract = new TenancyContract(contract); TenancyContract tenContract = new TenancyContract(contract);
tenContract.setStartDate(FormUtil.readString("Start Date")); System.out.println("Start Date:");
tenContract.setDuration(FormUtil.readInt("Duration")); Timestamp startDate = Timestamp.valueOf(FormUtil.readInt("Year")+"-"+FormUtil.readInt("Month")+"-"+FormUtil.readInt("Day"));
tenContract.setStartDate(startDate);
System.out.println("Duration:");
Timestamp duration = Timestamp.valueOf(FormUtil.readInt("Year")+"-"+FormUtil.readInt("Month")+"-"+FormUtil.readInt("Day"));
tenContract.setDuration(duration);
tenContract.setAdditionalCost(FormUtil.readInt("Additional Costs")); tenContract.setAdditionalCost(FormUtil.readInt("Additional Costs"));
//_orm.persist(tenContract); _orm.persist(tenContract);
} }
else{ else{
PurchaseContract purContract = new PurchaseContract(contract); PurchaseContract purContract = new PurchaseContract(contract);
purContract.setNoOfInstallments(FormUtil.readInt("No of Installments")); purContract.setNoOfInstallments(FormUtil.readInt("No of Installments"));
purContract.setInterestRate(FormUtil.readInt("Interest Rate")); purContract.setInterestRate(FormUtil.readInt("Interest Rate"));
//_orm.persist(purContract); _orm.persist(purContract);
} }
} }

13
02/src/de/dis2017/data/TenancyContract.java
View File

@ -1,10 +1,11 @@
package de.dis2017.data; package de.dis2017.data;
import java.sql.Timestamp;
import java.util.Date; import java.util.Date;
public class TenancyContract extends Contract { public class TenancyContract extends Contract {
private String startDate; private Timestamp startDate;
private int duration; private Timestamp duration;
private int additionalCost; private int additionalCost;
public TenancyContract(){ public TenancyContract(){
@ -17,19 +18,19 @@ public class TenancyContract extends Contract {
this.setPerson(contract.getPerson()); this.setPerson(contract.getPerson());
} }
public String getStartDate() { public Timestamp getStartDate() {
return startDate; return startDate;
} }
public void setStartDate(String startDate) { public void setStartDate(Timestamp startDate) {
this.startDate = startDate; this.startDate = startDate;
} }
public int getDuration() { public Timestamp getDuration() {
return duration; return duration;
} }
public void setDuration(int duration) { public void setDuration(Timestamp duration) {
this.duration = duration; this.duration = duration;
} }

100
02/src/de/dis2017/data/db/ORM.java
View File

@ -6,6 +6,8 @@ import de.dis2017.data.Estate;
import de.dis2017.data.EstateAgent; import de.dis2017.data.EstateAgent;
import de.dis2017.data.House; import de.dis2017.data.House;
import de.dis2017.data.Person; import de.dis2017.data.Person;
import de.dis2017.data.PurchaseContract;
import de.dis2017.data.TenancyContract;
import org.jetbrains.annotations.Nullable; import org.jetbrains.annotations.Nullable;
@ -655,7 +657,103 @@ public class ORM {
*/ */
public void persist(Contract contract) public void persist(Contract contract)
{ {
//TODO boolean changeFinished = false;
try {
_connection.setAutoCommit(false);
if (contract.getContractNo() == -1) {
String insertSQL = "INSERT INTO CONTRACT (date, place) " +
"VALUES (?, ?)";
PreparedStatement pstmt = _connection.prepareStatement(insertSQL, Statement.RETURN_GENERATED_KEYS);
pstmt.setString(1, contract.getDate());
pstmt.setString(2, contract.getPlace());
pstmt.executeUpdate();
ResultSet rs = pstmt.getGeneratedKeys();
if (rs.next()) {
contract.setContractNo(rs.getInt(1));
}
rs.close();
pstmt.close();
if (contract instanceof TenancyContract) {
TenancyContract tenContract = (TenancyContract) contract;
String insertSQLHouse = "INSERT INTO TENANCYCONTRACT (ContractNumber, StartDate, Duration, AdditionalCosts) VALUES (?, ?, ?, ?)";
PreparedStatement pstmtHouse = _connection.prepareStatement(insertSQLHouse);
pstmtHouse.setInt(1, tenContract.getContractNo());
pstmtHouse.setTimestamp(2, tenContract.getStartDate());
pstmtHouse.setTimestamp(3, tenContract.getDuration());
pstmtHouse.setInt(4, tenContract.getAdditionalCost());
pstmt.executeUpdate();
pstmtHouse.executeUpdate();
pstmt.close();
pstmtHouse.close();
changeFinished = true;
}
else if (contract instanceof PurchaseContract) {
PurchaseContract purContract = (PurchaseContract) contract;
String insertSQLApartment = "INSERT INTO PURCHASECONTRACT (ContractNumber, NumberOfInstallments, InterestRate) " +
"VALUES (?, ?, ?)";
PreparedStatement pstmtApartment = _connection.prepareStatement(insertSQLApartment);
pstmtApartment.setInt(1, purContract.getContractNo());
pstmtApartment.setInt(2, purContract.getNoOfInstallments());
pstmtApartment.setInt(3, purContract.getInterestRate());
pstmt.executeUpdate();
pstmtApartment.executeUpdate();
pstmt.close();
pstmtApartment.close();
changeFinished = true;
}
} else {
// create query
String updateSQL = "UPDATE CONTRACT SET date = ?, place = ? WHERE ContractNumber = ?";
PreparedStatement pstmt = _connection.prepareStatement(updateSQL);
pstmt.setString(1, contract.getDate());
pstmt.setString(2, contract.getPlace());
pstmt.setInt(3, contract.getContractNo());
if (contract instanceof TenancyContract) {
TenancyContract tenContract = (TenancyContract) contract;
String updateSQLHouse = "UPDATE TenancyContract SET startDate = ?, duration = ?, additionalcosts = ? WHERE contractNumber = ?";
PreparedStatement pstmtHouse = _connection.prepareStatement(updateSQLHouse);
pstmtHouse.setTimestamp(1, tenContract.getStartDate());
pstmtHouse.setTimestamp(2, tenContract.getDuration());
pstmtHouse.setInt(3, tenContract.getAdditionalCost());
pstmtHouse.setInt(4, tenContract.getContractNo());
pstmt.executeUpdate();
pstmtHouse.executeUpdate();
pstmt.close();
pstmtHouse.close();
changeFinished = true;
}
else if (contract instanceof PurchaseContract) {
PurchaseContract purContract = (PurchaseContract) contract;
String updateSQLApartment = "UPDATE PurchaseContract SET numberofinstallments = ?, interestrate = ? WHERE contractNumber = ?";
PreparedStatement pstmtApartment = _connection.prepareStatement(updateSQLApartment);
pstmtApartment.setInt(1, purContract.getNoOfInstallments());
pstmtApartment.setInt(2, purContract.getInterestRate());
pstmtApartment.setInt(3, purContract.getContractNo());
pstmt.executeUpdate();
pstmtApartment.executeUpdate();
pstmt.close();
pstmtApartment.close();
changeFinished = true;
}
}
if (changeFinished) {
_connection.commit();
if (!_contracts.containsKey(contract.getContractNo())) {
_contracts.put(contract.getContractNo(), contract);
}
}
_connection.setAutoCommit(true);
} catch (SQLException e) {
try {
_connection.rollback();
} catch (SQLException e1) {
e1.printStackTrace();
}
e.printStackTrace();
}
} }
/** /**