Suggest a feature
×

Welcome to TagMyCode

Please login or create account to add a snippet.
0
0
 
0
Language: Java
Posted by: Ioannis Angelis
Added: Sep 14, 2021 5:29 PM
Views: 160
Tags: crud jdbc
  1. package org.websparrow.dao;
  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.  
  9. public class Admin {
  10.  
  11.         // method for create connection
  12.         public static Connection getConnection() throws Exception {
  13.                 try {
  14.                         Class.forName("com.mysql.jdbc.Driver");
  15.                         return DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/websparrow", "root", "");
  16.                 } catch (Exception e) {
  17.                         e.printStackTrace();
  18.                         return null;
  19.                 }
  20.         }
  21.  
  22.         // method for save user data in database
  23.         public int registerUser(String uname, String uemail, String upass, String udeg, boolean returnKey)
  24.                         throws Exception {
  25.                 getConnection().setAutoCommit(false);
  26.                 int i = 0;
  27.                 try {
  28.                         String sql = "INSERT INTO STRUTS2CRUD VALUES (?,?,?,?)";
  29.                         PreparedStatement ps = getConnection().prepareStatement(sql);
  30.                         ps.setString(1, uname);
  31.                         ps.setString(2, uemail);
  32.                         ps.setString(3, upass);
  33.                         ps.setString(4, udeg);
  34.                         i = ps.executeUpdate();
  35.                         ResultSet rs = ps.getGeneratedKeys();
  36.                         if (rs.next() && returnKey) {
  37.                                 i = rs.getInt(1);
  38.                         }
  39.                         getConnection().commit();
  40.                         return i;
  41.                 } catch (Exception e) {
  42.                         e.printStackTrace();
  43.                         getConnection().rollback();
  44.                         return i;
  45.                 } finally {
  46.                         if (getConnection() != null) {
  47.                                 getConnection().close();
  48.                         }
  49.                 }
  50.         }
  51.  
  52.         // method for fetch saved user data
  53.         public ResultSet report() throws SQLException, Exception {
  54.                 ResultSet rs = null;
  55.                 try {
  56.                         String sql = "SELECT UNAME,UEMAIL,UPASS,UDEG FROM STRUTS2CRUD";
  57.                         PreparedStatement ps = getConnection().prepareStatement(sql);
  58.                         rs = ps.executeQuery();
  59.                         return rs;
  60.                 } catch (Exception e) {
  61.                         e.printStackTrace();
  62.                         return null;
  63.                 } finally {
  64.                         if (getConnection() != null) {
  65.                                 getConnection().close();
  66.                         }
  67.                 }
  68.         }
  69.  
  70.         // method for fetch old data to be update
  71.         public ResultSet fetchUserDetails(String uemail) throws SQLException, Exception {
  72.                 ResultSet rs = null;
  73.                 try {
  74.                         String sql = "SELECT UNAME,UEMAIL,UPASS,UDEG FROM STRUTS2CRUD WHERE UEMAIL=?";
  75.                         PreparedStatement ps = getConnection().prepareStatement(sql);
  76.                         ps.setString(1, uemail);
  77.                         rs = ps.executeQuery();
  78.                         return rs;
  79.                 } catch (Exception e) {
  80.                         e.printStackTrace();
  81.                         return null;
  82.                 } finally {
  83.                         if (getConnection() != null) {
  84.                                 getConnection().close();
  85.                         }
  86.                 }
  87.         }
  88.  
  89.         // method for update new data in database
  90.         public int updateUserDetails(String uname, String uemail, String upass, String udeg, String uemailhidden)
  91.                         throws SQLException, Exception {
  92.                 getConnection().setAutoCommit(false);
  93.                 int i = 0;
  94.                 try {
  95.                         String sql = "UPDATE STRUTS2CRUD SET UNAME=?,UEMAIL=?,UPASS=?,UDEG=? WHERE UEMAIL=?";
  96.                         PreparedStatement ps = getConnection().prepareStatement(sql);
  97.                         ps.setString(1, uname);
  98.                         ps.setString(2, uemail);
  99.                         ps.setString(3, upass);
  100.                         ps.setString(4, udeg);
  101.                         ps.setString(5, uemailhidden);
  102.                         i = ps.executeUpdate();
  103.                         getConnection().commit();
  104.                         return i;
  105.                 } catch (Exception e) {
  106.                         e.printStackTrace();
  107.                         getConnection().rollback();
  108.                         return 0;
  109.                 } finally {
  110.                         if (getConnection() != null) {
  111.                                 getConnection().close();
  112.                         }
  113.                 }
  114.         }
  115.  
  116.         // method for delete the record
  117.         public int deleteUserDetails(String uemail) throws SQLException, Exception {
  118.                 getConnection().setAutoCommit(false);
  119.                 int i = 0;
  120.                 try {
  121.                         String sql = "DELETE FROM STRUTS2CRUD WHERE UEMAIL=?";
  122.                         PreparedStatement ps = getConnection().prepareStatement(sql);
  123.                         ps.setString(1, uemail);
  124.                         i = ps.executeUpdate();
  125.                         getConnection().commit();
  126.                         return i;
  127.                 } catch (Exception e) {
  128.                         e.printStackTrace();
  129.                         getConnection().rollback();
  130.                         return 0;
  131.                 } finally {
  132.                         if (getConnection() != null) {
  133.                                 getConnection().close();
  134.                         }
  135.                 }
  136.         }
  137. }