Advertisement
Guest User

Untitled

a guest
Dec 14th, 2016
82
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 11.27 KB | None | 0 0
  1. package database;
  2.  
  3. import java.sql.Connection;
  4. import java.sql.DriverManager;
  5. import java.sql.PreparedStatement;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  8. import java.util.ArrayList;
  9. import java.util.List;
  10.  
  11. import domain.Kunde;
  12.  
  13. public class KundeSøgning {
  14.  
  15. public List<Kunde> SøgKunde(Kunde kunde) {
  16. List<Kunde> list = new ArrayList<>();
  17. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  18. PreparedStatement statement = connection.prepareStatement("SELECT navn,adresse,telefonnummer, cpr_cvr, kundeid from kundeoplysninger where upper(navn) like ? and upper(adresse) like ? and upper(telefonnummer) like ? and upper(cpr_cvr) like ? and kundeid like ?");) {
  19.  
  20. statement.setString(1, "%"+kunde.getNavn().toUpperCase()+"%");
  21. statement.setString(2, "%"+kunde.getAdresse().toUpperCase()+"%");
  22. statement.setString(3, "%"+kunde.getTelefon().toUpperCase()+"%");
  23. statement.setString(4, "%"+kunde.getCpr_cvr().toUpperCase()+"%");
  24. statement.setString(5, "%"+kunde.getKundeid()+"%");
  25.  
  26. ResultSet rs = statement.executeQuery();
  27.  
  28. while (rs.next()) {
  29. Kunde k = new Kunde();
  30. k.setNavn(rs.getString("navn"));
  31. k.setAdresse(rs.getString("adresse"));
  32. k.setTelefon(rs.getString("telefonnummer"));
  33. k.setCpr_cvr(rs.getString("cpr_cvr"));
  34. k.setKundeid(rs.getString("kundeid"));
  35. list.add(k);
  36.  
  37. }
  38.  
  39. } catch (SQLException e) {
  40. e.printStackTrace();
  41. }
  42. return list;
  43.  
  44. }
  45.  
  46. }
  47.  
  48.  
  49.  
  50.  
  51.  
  52. package database;
  53.  
  54. import java.sql.Connection;
  55. import java.sql.DriverManager;
  56. import java.sql.PreparedStatement;
  57. import java.sql.SQLException;
  58.  
  59. import domain.Kunde;
  60.  
  61. public class KundeVedligehold {
  62. public void Opretkunde(Kunde kunde) {
  63. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  64. PreparedStatement statement = connection.prepareStatement(
  65. "INSERT INTO KUNDEOPLYSNINGER (NAVN, ADRESSE, FØDSELSDAG, POSTNUMMER, TELEFONNUMMER, EMAIL, CPR_CVR ) VALUES ( ?, ?, ?, ?, ?, ?, ?)");) {
  66. try {
  67. connection.setAutoCommit(false);
  68. statement.setString(1, kunde.getNavn()); // NAVN
  69. statement.setString(2, kunde.getAdresse()); // ADRESSE
  70. statement.setString(3, kunde.getFødselsdag()); // FØDSELSDAG
  71. statement.setString(4, kunde.getPostnummer()); // POSTNUMMER
  72. statement.setString(5, kunde.getTelefon()); // TELEFONNUMMER
  73. statement.setString(6, kunde.getEmail()); // EMAIL
  74. statement.setString(7, kunde.getCpr_cvr()); // CPR_CVR
  75. int antal = statement.executeUpdate();
  76. System.out.println("Antal rækker berørt : " + antal);
  77. connection.commit();
  78. } catch (SQLException e) {
  79. System.out.println("vi når her til");
  80. connection.rollback();
  81. }
  82. } catch (SQLException e) {
  83. e.printStackTrace();
  84. }
  85.  
  86. }
  87. public void RedigerKunde(Kunde kunde) {
  88. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  89. PreparedStatement statement = connection.prepareStatement("update kundeoplysninger set navn = ?, adresse = ?, telefonnummer = ?, cpr_cvr = ? where kundeid = ?");) {
  90. try {
  91. connection.setAutoCommit(false);
  92. statement.setString(1, kunde.getNavn()); // NAVN
  93. // statement.setString(2, kunde.getKundeid());
  94. statement.setString(2, kunde.getAdresse()); // ADRESSE
  95. // statement.setString(4, kunde.getKundeid());
  96. statement.setString(3, kunde.getTelefon()); // TELEFONNUMMER
  97. // statement.setString(6, kunde.getKundeid());
  98. statement.setString(4, kunde.getCpr_cvr()); // EMAIL
  99. statement.setString(5, kunde.getKundeid());
  100. int antal = statement.executeUpdate();
  101. System.out.println("Antal rækker berørt : " + antal);
  102. connection.commit();
  103. } catch (SQLException e) {
  104. System.out.println("vi når her til");
  105. connection.rollback();
  106. }
  107. } catch (SQLException e) {
  108. e.printStackTrace();
  109. }
  110.  
  111. }
  112. }
  113.  
  114.  
  115.  
  116.  
  117. package database;
  118.  
  119. import java.math.BigDecimal;
  120. import java.sql.Connection;
  121. import java.sql.Date;
  122. import java.sql.DriverManager;
  123. import java.sql.PreparedStatement;
  124. import java.sql.ResultSet;
  125. import java.sql.SQLException;
  126. import java.sql.Timestamp;
  127. import java.time.LocalDate;
  128. import java.time.LocalDateTime;
  129.  
  130. import domain.Overførsel;
  131.  
  132. public class Overførseler {
  133.  
  134. public Overførsel findkontoer(Overførsel overførsel) {
  135. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  136. PreparedStatement statement = connection
  137. .prepareStatement("SELECT saldo, kontonummer from kontooplysninger where kontonummer = ?");) {
  138.  
  139. statement.setString(1, overførsel.getFraKonto());
  140. ResultSet rs = statement.executeQuery();
  141. if (rs.next()) {
  142.  
  143. overførsel.setFraKontoSaldo(rs.getBigDecimal("saldo"));
  144. }
  145.  
  146. statement.setString(1, overførsel.getTilKonto());
  147. rs = statement.executeQuery();
  148. if (rs.next()) {
  149. overførsel.setTilKontoSaldo(rs.getBigDecimal("saldo"));
  150. }
  151.  
  152. } catch (SQLException e) {
  153. e.printStackTrace();
  154. }
  155. return overførsel;
  156. }
  157.  
  158. public void Overfør(Overførsel overførsel) {
  159. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  160. PreparedStatement statement1 = connection.prepareStatement(
  161. "INSERT INTO POSTERINGER (KONTONUMMER, BELOB, POSTERINGSTEKST, POSTERINGSDATO ) VALUES ( ?, ?, ?, ?);");
  162. PreparedStatement statement2 = connection.prepareStatement(
  163. "INSERT INTO POSTERINGER (KONTONUMMER, BELOB, POSTERINGSTEKST, POSTERINGSDATO ) VALUES ( ?, ?, ?, ?);");
  164. PreparedStatement statement3 = connection
  165. .prepareStatement("update kontooplysninger SET saldo=? WHERE kontonummer = ?;");
  166. PreparedStatement statement4 = connection
  167. .prepareStatement("update kontooplysninger SET saldo=? WHERE kontonummer = ?;");
  168. // + "INSERT INTO POSTERINGER (KONTONUMMER, BELOB, POSTERINGSTEKST,
  169. // POSTERINGSDATO ) VALUES ( ?, ?, ?, ?);"
  170. // + "UPDATE kontooplysninger SET saldo=? WHERE kontonummer = ?; "
  171. // + "update kontooplysninger SET saldo=? WHERE kontonummer = ?;");
  172.  
  173. ) {
  174. try {
  175. connection.setAutoCommit(false);
  176. statement1.setString(1, overførsel.getFraKonto()); // FraKonto
  177. statement1.setString(2, "-" + overførsel.getBeløb().toString()); // ADRESSE
  178. statement1.setString(3, overførsel.getFraPostering()); // FØDSELSDAG
  179. statement1.setDate(4, Date.valueOf(LocalDate.now())); // POSTNUMMER
  180. statement1.executeUpdate();
  181.  
  182. statement2.setString(1, overførsel.getTilKonto()); // TELEFONNUMMER
  183. statement2.setString(2, "+" + overførsel.getBeløb().toString()); // EMAIL
  184. statement2.setString(3, overførsel.getTilPostering()); // CPR_CVR
  185. statement2.setDate(4, Date.valueOf(LocalDate.now())); // CPR_CVR
  186. statement2.executeUpdate();
  187.  
  188. statement3.setBigDecimal(1, overførsel.getFraKontoSaldo()); // CPR_CVR
  189. statement3.setString(2, overførsel.getFraKonto()); // CPR_CVR
  190. statement3.executeUpdate();
  191.  
  192. statement4.setBigDecimal(1, overførsel.getTilKontoSaldo());
  193. statement4.setString(2, overførsel.getTilKonto());
  194. statement4.executeUpdate();
  195.  
  196. // int antal = statement1.executeUpdate();
  197. System.out.println(overførsel.getFraKonto() + " her " + overførsel.getFraKontoSaldo());
  198. System.out.println("Hej Morten");
  199. connection.commit();
  200. } catch (SQLException e) {
  201. System.out.println("vi når her til");
  202. connection.rollback();
  203. }
  204. } catch (
  205.  
  206. SQLException e) {
  207. e.printStackTrace();
  208. System.out.println("fejl");
  209. }
  210. }
  211.  
  212. public void Indsætning(Overførsel indsæt) {
  213. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  214. PreparedStatement statement1 = connection.prepareStatement(
  215. "INSERT INTO POSTERINGER (KONTONUMMER, BELOB, POSTERINGSTEKST, POSTERINGSDATO ) VALUES ( ?, ?, ?, ?);");
  216. PreparedStatement statement2 = connection
  217. .prepareStatement("update kontooplysninger SET saldo=? WHERE kontonummer = ?;");) {
  218. try {
  219. connection.setAutoCommit(false);
  220. statement1.setString(1, indsæt.getTilKonto()); // FraKonto
  221. statement1.setString(2, indsæt.getBeløb().toString()); // ADRESSE
  222. statement1.setString(3, indsæt.getTilPostering()); // FØDSELSDAG
  223. statement1.setDate(4, Date.valueOf(LocalDate.now())); // POSTNUMMER
  224. statement1.executeUpdate();
  225.  
  226. statement2.setBigDecimal(1, indsæt.getTilKontoSaldo()); // CPR_CVR
  227. statement2.setString(2, indsæt.getTilKonto()); // CPR_CVR
  228. statement2.executeUpdate();
  229. System.out.println("Hej Morten");
  230. connection.commit();
  231.  
  232. } catch (SQLException e) {
  233. System.out.println("vi når her til");
  234. connection.rollback();
  235. }
  236. } catch (
  237.  
  238. SQLException e) {
  239. e.printStackTrace();
  240. System.out.println("fejl");
  241. }
  242.  
  243. }
  244.  
  245. }
  246.  
  247.  
  248.  
  249.  
  250.  
  251. package database;
  252.  
  253. import java.sql.Connection;
  254. import java.sql.Date;
  255. import java.sql.DriverManager;
  256. import java.sql.PreparedStatement;
  257. import java.sql.ResultSet;
  258. import java.sql.SQLException;
  259. import java.time.LocalDate;
  260. import java.util.ArrayList;
  261. import java.util.List;
  262.  
  263. import domain.Konto;
  264.  
  265. public class SpecifikKundeDB {
  266.  
  267. public List<Konto> KontoOversigt(Konto konto) {
  268. List<Konto> list = new ArrayList<>();
  269. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  270. PreparedStatement statement = connection
  271. .prepareStatement("select navn, kontonavn, kundeid, kontonummer, saldo from kundeoplysninger "
  272. + "join kontooplysninger " + "on kundeoplysninger.kundeid = kontooplysninger.kundeid "
  273. + "where kundeid = ?");) {
  274.  
  275. statement.setString(1, konto.getKundeid());
  276.  
  277. // statement.setString(4, "%"+konto.getKontoNavn.toUpperCase()+"%");
  278. ResultSet rs = statement.executeQuery();
  279.  
  280. while (rs.next()) {
  281. Konto k = new Konto();
  282. k.setKontonummer(rs.getString("kontonummer"));
  283. k.setSaldo(rs.getString("saldo"));
  284. // k.setKundeid(rs.getString("kundeid"));
  285. k.setKontoNavn(rs.getString("kontonavn"));
  286. list.add(k);
  287. }
  288.  
  289. } catch (SQLException e) {
  290. e.printStackTrace();
  291. }
  292. return list;
  293. }
  294.  
  295. public void Opretkonto(Konto konto) {
  296. try (Connection connection = DriverManager.getConnection("jdbc:hsqldb:hsql://localhost/mydb", "SA", "");
  297. PreparedStatement statement = connection.prepareStatement(
  298. "INSERT INTO KONTOOPLYSNINGER ( KONTONUMMER, SALDO, KUNDEID, STARTDATO, SLUTDATO, KONTONAVN ) "
  299. + "VALUES (? ,? ,? ,?, ?, ?)");) {
  300. try {
  301. connection.setAutoCommit(false);
  302. statement.setString(1, konto.getKontonummer()); // Kontonummer
  303. statement.setString(2, konto.getSaldo()); // saldo
  304. statement.setString(3, konto.getKundeid()); // kundeid
  305. statement.setDate(4, Date.valueOf(LocalDate.now())); // startdato(oprettelses dato)
  306. statement.setDate(5, Date.valueOf(LocalDate.of(9999, 12, 31))); // slutdato(9999-12-31)
  307. statement.setString(6, konto.getKontoNavn()); // kontonavn
  308. int antal = statement.executeUpdate();
  309.  
  310. System.out.println("Antal rækker berørt : " + antal);
  311. connection.commit();
  312. } catch (SQLException e) {
  313. System.out.println("vi når her til");
  314. connection.rollback();
  315. }
  316. } catch (SQLException e) {
  317. e.printStackTrace();
  318. }
  319.  
  320. }
  321. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement