JAVAWEB网上商城项目实现DAO层的编写设计------JAVA

左手的ㄟ右手 2024-03-03 08:58 64阅读 0赞

>     package dao;
>     
>     import bean.*;
>     import java.sql.Connection;
>     import java.sql.SQLException;
>     import java.sql.Statement;
>     
>     public class insert
>     {
>         private Statement statement = null;
>         private Connection connection = Mysql.getMysql().getConnection();
>         public insert()
>         {
>             try
>             {
>                 statement = connection.createStatement();
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public int insertUser(user u)
>         {
>             int count = 0;
>             int checkId = new select().check(u.getEmail());
>             try
>             {
>                 String sql = "insert into users(Email,pssword,username) values" + "('" + u.getEmail() + "','" + u.getPassword() + "','" + u.getName() + "')";
>                 if(checkId == 0)
>                 {
>                     count = statement.executeUpdate(sql);
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>     
>         public int insertManager(Manager Manager)
>         {
>             int count = 0;
>             try
>             {
>                 String sql = "insert into managers(Email,pssword,username) values" + "('" + Manager.getEmail() + "','" + Manager.getPassword() + "','" + Manager.getName() + "')";
>                 count = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>         public int AddProduct(product product)
>         {
>             int count = 0;
>             try
>             {
>                 String sql = "insert into product(product_name,brand_name,amount,price,description,type_name,statue) values" + "('" + product.getProduct_name() + "','" + product.getBrand_name() + "','" + product.getAmount() + "','" + product.getPrice() + "','" + product.getDescription() + "','" + product.getType_name() + "','available')";
>                 count = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>     
>         public int AddCart(int num,String product_name,String email,int amount)
>         {
>             int count = 0;
>             try
>             {
>                 String sql = "insert into shoppingcart(num,email,product_name,amount) values" + "(" + num + ",'"+ email + "','" + product_name + "','" + amount + "')";
>                 count = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>     }
> 
>     package dao;
>     
>     import bean.*;
>     import java.sql.Connection;
>     import java.sql.SQLException;
>     import java.sql.Statement;
>     
>     public class insert
>     {
>         private Statement statement = null;
>         private Connection connection = Mysql.getMysql().getConnection();
>         public insert()
>         {
>             try
>             {
>                 statement = connection.createStatement();
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public int insertUser(user u)
>         {
>             int count = 0;
>             int checkId = new select().check(u.getEmail());
>             try
>             {
>                 String sql = "insert into users(Email,pssword,username) values" + "('" + u.getEmail() + "','" + u.getPassword() + "','" + u.getName() + "')";
>                 if(checkId == 0)
>                 {
>                     count = statement.executeUpdate(sql);
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>     
>         public int insertManager(Manager Manager)
>         {
>             int count = 0;
>             try
>             {
>                 String sql = "insert into managers(Email,pssword,username) values" + "('" + Manager.getEmail() + "','" + Manager.getPassword() + "','" + Manager.getName() + "')";
>                 count = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>         public int AddProduct(product product)
>         {
>             int count = 0;
>             try
>             {
>                 String sql = "insert into product(product_name,brand_name,amount,price,description,type_name,statue) values" + "('" + product.getProduct_name() + "','" + product.getBrand_name() + "','" + product.getAmount() + "','" + product.getPrice() + "','" + product.getDescription() + "','" + product.getType_name() + "','available')";
>                 count = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>     
>         public int AddCart(int num,String product_name,String email,int amount)
>         {
>             int count = 0;
>             try
>             {
>                 String sql = "insert into shoppingcart(num,email,product_name,amount) values" + "(" + num + ",'"+ email + "','" + product_name + "','" + amount + "')";
>                 count = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>     }

>     package dao;
>     
>     import java.sql.*;
>     import java.util.ResourceBundle;
>     
>     public class Mysql
>     {
>         private ResourceBundle bundle = ResourceBundle.getBundle("Mysql");
>         private String url = bundle.getString("url");
>         private String user = bundle.getString("user");
>         private String password = bundle.getString("password");
>         private static Statement statement = null;
>         private static Connection connection = null;
>         private static Mysql mysql = new Mysql();
>         private Mysql(){}
>         //public
>         public static Mysql getMysql()
>         {
>             return mysql;
>         }
>         public Connection getConnection()
>         {
>             try
>             {
>                 DriverManager.registerDriver(new com.mysql.jdbc.Driver());
>                 connection = DriverManager.getConnection(url,user,password);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return connection;
>         }
>         public static void close()
>         {
>             try
>             {
>                 if(statement != null)
>                 {
>                     statement.close();
>                 }
>                 if(connection != null)
>                 {
>                     connection.close();
>                 }
>             }
>             catch(SQLException e)
>             {
>                 e.printStackTrace();
>             }
>         }
>     }
> 
>     package dao;
>     
>     import java.sql.*;
>     import java.util.ResourceBundle;
>     
>     public class Mysql
>     {
>         private ResourceBundle bundle = ResourceBundle.getBundle("Mysql");
>         private String url = bundle.getString("url");
>         private String user = bundle.getString("user");
>         private String password = bundle.getString("password");
>         private static Statement statement = null;
>         private static Connection connection = null;
>         private static Mysql mysql = new Mysql();
>         private Mysql(){}
>         //public
>         public static Mysql getMysql()
>         {
>             return mysql;
>         }
>         public Connection getConnection()
>         {
>             try
>             {
>                 DriverManager.registerDriver(new com.mysql.jdbc.Driver());
>                 connection = DriverManager.getConnection(url,user,password);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return connection;
>         }
>         public static void close()
>         {
>             try
>             {
>                 if(statement != null)
>                 {
>                     statement.close();
>                 }
>                 if(connection != null)
>                 {
>                     connection.close();
>                 }
>             }
>             catch(SQLException e)
>             {
>                 e.printStackTrace();
>             }
>         }
>     }

>     package dao;
>     
>     import java.sql.*;
>     import bean.*;
>     import Enum.*;
>     
>     public class select
>     {
>         private Connection connection = Mysql.getMysql().getConnection();
>         private Statement statement = null;
>         private ResultSet resultSet = null;
>         private String UserSql = "select * from users;";
>         private String ManagerSql = "select * from managers;";
>         private static String ProductSql = "select * from product;";
>         private String CartSql = "select * from shoppingcart";
>         private String FoodSql = "select * from product where type_name = '美食'";
>         public select()
>         {
>             try
>             {
>                 statement = connection.createStatement();
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public Connection getConnection()
>         {
>             return connection;
>         }
>         public void setConnection(Connection connection)
>         {
>             this.connection = connection;
>         }
>         public Statement getStatement()
>         {
>             return statement;
>         }
>         public ResultSet getResultSet() {
>             return resultSet;
>         }
>         public ResultSet LoginUser()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(UserSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>         public ResultSet LoginManager()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(ManagerSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>         public int check(String email)
>         {
>             int checkId = 0;
>             try
>             {
>                 resultSet = statement.executeQuery(UserSql);
>                 while(resultSet.next())
>                 {
>                     String checkEmail = resultSet.getString("email");
>                     if(checkEmail.equals(email))
>                     {
>                         checkId = 1;
>                         break;
>                     }
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return checkId;
>         }
>         public int checkProduct(String product_Name)
>         {
>             int checkId = 0;
>             try
>             {
>                 resultSet = statement.executeQuery(ProductSql);
>                 l:while(resultSet.next())
>                 {
>                     String checkProduct = resultSet.getString("product_Name");
>                     if(checkProduct.equals(product_Name))
>                     {
>                         checkId = 1;
>                         break l;
>                     }
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return checkId;
>         }
>         public product getProduct(String product_name)
>         {
>             product product = null;
>             if(new select().checkProduct(product_name) == 1)
>             {
>                 try
>                 {
>                     String getProduct = "select * from product where product_name = '" + product_name + "'";
>                     resultSet = statement.executeQuery(getProduct);
>                     l:while(resultSet.next())
>                     {
>                         String brand_name = resultSet.getString("brand_name");
>                         int amount = Integer.parseInt(resultSet.getString("amount"));
>                         double price = Double.parseDouble(resultSet.getString("price"));
>                         String description = resultSet.getString("description");
>                         String type_name = resultSet.getString("type_name");
>                         ProductStatue statue = ProductStatue.valueOf(resultSet.getString("statue"));
>                         product = new product(product_name,brand_name,amount,price,description,type_name,statue);
>                         break l;
>                     }
>                 }
>                 catch (SQLException e)
>                 {
>                     throw new RuntimeException(e);
>                 }
>             }
>             return product;
>         }
>         public int getNum(String email,String product_name)
>         {
>             int num = 0;
>             String sql = "SELECT * FROM shoppingcart WHERE email = '" + email + "' && product_name = '" + product_name + "';";
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     num = Integer.parseInt(resultSet.getString("amount"));
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return num;
>         }
>         public product GetProduct(String product_name)
>         {
>             product product = null;
>             String sql = "select * from product where product_name = '" + product_name + "';";
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     String brand_name = resultSet.getString("brand_name");
>                     int amount = Integer.parseInt(resultSet.getString("amount"));
>                     double price = Double.parseDouble(resultSet.getString("price"));
>                     String type_name = resultSet.getString("type_name");
>                     String description = resultSet.getString("type_name");
>                     ProductStatue statue = ProductStatue.valueOf(resultSet.getString("statue"));
>                     product = new product(product_name,brand_name,amount,price,description,type_name,statue);
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return product;
>         }
>         public int num(String product_name)
>         {
>             int num = 0;
>             String sql = "select amount from product where product_name = '" + product_name + "'";
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     num = resultSet.getInt(1);
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return num;
>         }
>         public user getUser(String email)
>         {
>             user user = new user();
>             String sql = "select * from users where email = '" + email + "'";
>             if(new select().check(email) == 1)
>             {
>                 try
>                 {
>                     resultSet = statement.executeQuery(sql);
>                     while(resultSet.next())
>                     {
>                         user.setEmail(email);
>                         String username = resultSet.getString("username");
>                         String password = resultSet.getString("pssword");
>                         user.setName(username);
>                         user.setPassword(password);
>                     }
>                 }
>                 catch (SQLException e)
>                 {
>                     throw new RuntimeException(e);
>                 }
>             }
>             return user;
>         }
>         public ResultSet getFood()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(FoodSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>     
>         public ResultSet getCart()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(CartSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>         public int checkCart(String email,String product_name)
>         {
>             String sql = "select * from shoppingcart where product_name ='" + product_name + "';";
>             int checkId = 0;
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     String checkEmail = resultSet.getString("email");
>                     if(checkEmail.equals(email))
>                     {
>                         checkId = 1;
>                         break;
>                     }
>                 }
>             }
>             catch(SQLException e)
>             {
>                 e.printStackTrace();
>             }
>             return checkId;
>         }
>     }
> 
>     package dao;
>     
>     import java.sql.*;
>     import bean.*;
>     import Enum.*;
>     
>     public class select
>     {
>         private Connection connection = Mysql.getMysql().getConnection();
>         private Statement statement = null;
>         private ResultSet resultSet = null;
>         private String UserSql = "select * from users;";
>         private String ManagerSql = "select * from managers;";
>         private static String ProductSql = "select * from product;";
>         private String CartSql = "select * from shoppingcart";
>         private String FoodSql = "select * from product where type_name = '美食'";
>         public select()
>         {
>             try
>             {
>                 statement = connection.createStatement();
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public Connection getConnection()
>         {
>             return connection;
>         }
>         public void setConnection(Connection connection)
>         {
>             this.connection = connection;
>         }
>         public Statement getStatement()
>         {
>             return statement;
>         }
>         public ResultSet getResultSet() {
>             return resultSet;
>         }
>         public ResultSet LoginUser()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(UserSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>         public ResultSet LoginManager()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(ManagerSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>         public int check(String email)
>         {
>             int checkId = 0;
>             try
>             {
>                 resultSet = statement.executeQuery(UserSql);
>                 while(resultSet.next())
>                 {
>                     String checkEmail = resultSet.getString("email");
>                     if(checkEmail.equals(email))
>                     {
>                         checkId = 1;
>                         break;
>                     }
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return checkId;
>         }
>         public int checkProduct(String product_Name)
>         {
>             int checkId = 0;
>             try
>             {
>                 resultSet = statement.executeQuery(ProductSql);
>                 l:while(resultSet.next())
>                 {
>                     String checkProduct = resultSet.getString("product_Name");
>                     if(checkProduct.equals(product_Name))
>                     {
>                         checkId = 1;
>                         break l;
>                     }
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return checkId;
>         }
>         public product getProduct(String product_name)
>         {
>             product product = null;
>             if(new select().checkProduct(product_name) == 1)
>             {
>                 try
>                 {
>                     String getProduct = "select * from product where product_name = '" + product_name + "'";
>                     resultSet = statement.executeQuery(getProduct);
>                     l:while(resultSet.next())
>                     {
>                         String brand_name = resultSet.getString("brand_name");
>                         int amount = Integer.parseInt(resultSet.getString("amount"));
>                         double price = Double.parseDouble(resultSet.getString("price"));
>                         String description = resultSet.getString("description");
>                         String type_name = resultSet.getString("type_name");
>                         ProductStatue statue = ProductStatue.valueOf(resultSet.getString("statue"));
>                         product = new product(product_name,brand_name,amount,price,description,type_name,statue);
>                         break l;
>                     }
>                 }
>                 catch (SQLException e)
>                 {
>                     throw new RuntimeException(e);
>                 }
>             }
>             return product;
>         }
>         public int getNum(String email,String product_name)
>         {
>             int num = 0;
>             String sql = "SELECT * FROM shoppingcart WHERE email = '" + email + "' && product_name = '" + product_name + "';";
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     num = Integer.parseInt(resultSet.getString("amount"));
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return num;
>         }
>         public product GetProduct(String product_name)
>         {
>             product product = null;
>             String sql = "select * from product where product_name = '" + product_name + "';";
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     String brand_name = resultSet.getString("brand_name");
>                     int amount = Integer.parseInt(resultSet.getString("amount"));
>                     double price = Double.parseDouble(resultSet.getString("price"));
>                     String type_name = resultSet.getString("type_name");
>                     String description = resultSet.getString("type_name");
>                     ProductStatue statue = ProductStatue.valueOf(resultSet.getString("statue"));
>                     product = new product(product_name,brand_name,amount,price,description,type_name,statue);
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return product;
>         }
>         public int num(String product_name)
>         {
>             int num = 0;
>             String sql = "select amount from product where product_name = '" + product_name + "'";
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     num = resultSet.getInt(1);
>                 }
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return num;
>         }
>         public user getUser(String email)
>         {
>             user user = new user();
>             String sql = "select * from users where email = '" + email + "'";
>             if(new select().check(email) == 1)
>             {
>                 try
>                 {
>                     resultSet = statement.executeQuery(sql);
>                     while(resultSet.next())
>                     {
>                         user.setEmail(email);
>                         String username = resultSet.getString("username");
>                         String password = resultSet.getString("pssword");
>                         user.setName(username);
>                         user.setPassword(password);
>                     }
>                 }
>                 catch (SQLException e)
>                 {
>                     throw new RuntimeException(e);
>                 }
>             }
>             return user;
>         }
>         public ResultSet getFood()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(FoodSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>     
>         public ResultSet getCart()
>         {
>             try
>             {
>                 resultSet = statement.executeQuery(CartSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return resultSet;
>         }
>         public int checkCart(String email,String product_name)
>         {
>             String sql = "select * from shoppingcart where product_name ='" + product_name + "';";
>             int checkId = 0;
>             try
>             {
>                 resultSet = statement.executeQuery(sql);
>                 while(resultSet.next())
>                 {
>                     String checkEmail = resultSet.getString("email");
>                     if(checkEmail.equals(email))
>                     {
>                         checkId = 1;
>                         break;
>                     }
>                 }
>             }
>             catch(SQLException e)
>             {
>                 e.printStackTrace();
>             }
>             return checkId;
>         }
>     }

>     package dao;
>     
>     import bean.product;
>     import bean.user;
>     
>     import java.sql.Connection;
>     import java.sql.SQLException;
>     import java.sql.Statement;
>     
>     public class Update
>     {
>         private Connection connection = Mysql.getMysql().getConnection();
>         private Statement statement = null;
>     
>         public Update()
>         {
>             try
>             {
>                 statement = connection.createStatement();
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>     
>         public int ChangePassword(user u)
>         {
>             int result = 0;
>             int checkId = new select().check(u.getEmail());
>             if(checkId == 1)
>             {
>                 try
>                 {
>                     String sql = "UPDATE users SET pssword '" + u.getPassword() + "' WHERE email='" + u.getEmail() + "'";
>                     result = statement.executeUpdate(sql);
>                 }
>                 catch (SQLException e)
>                 {
>                     throw new RuntimeException(e);
>                 }
>             }
>             return result;
>         }
>     
>         public int delCart(String email)
>         {
>             int result = 0;
>             String DelSql = "DELETE FROM shoppingcart WHERE email = '" + email + "'";
>             int count = 0;
>             try
>             {
>                 count = statement.executeUpdate(DelSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             if (count != 0)
>             {
>                 result = 1;
>             }
>             return result;
>         }
>     
>         public void AddNum(String email,String product_name)
>         {
>     
>             String sql = "update shoppingcart SET amount = " + (new select().getNum(email,product_name) + 1) + " where email = '" + email + "' && product_name = '" + String.format("%s", product_name) + "'";
>             try
>             {
>                 statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public void SubNum(String email,String product_name)
>         {
>             int amount = new select().getNum(email,product_name);
>             String sql = "update shoppingcart SET amount = " + (amount- 1)  + " where email = '" + email + "' && product_name = '" + String.format("%s", product_name) + "'";
>             if(amount > 1)
>             {
>                 try
>                 {
>                     statement.executeUpdate(sql);
>                 }
>                 catch(SQLException e)
>                 {
>                     e.printStackTrace();
>                 }
>             }
>         }
>         public int AddNUM(int num,String product_name)
>         {
>             int count = new select().num(product_name) + num;
>             int result = 0;
>             String sql = "update product set amount = " + count + " where product_name = '" + product_name + "'";
>             try
>             {
>                 result = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return result;
>         }
>         public int DelProduct(String product_name)
>         {
>             String DelSql = "DELETE FROM product WHERE product_name = '" + product_name + "'";
>             int count = 0;
>             try
>             {
>                 count = statement.executeUpdate(DelSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>         public int DelUser(String email)
>         {
>             String DelSql = "DELETE FROM users WHERE email = '" + email + "'";
>             int count = 0;
>             try
>             {
>                 count = statement.executeUpdate(DelSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>         public void addNum(String product_name,int amount,String email)
>         {
>             int OldAmount = new select().getNum(email,product_name);
>             int NewAmount = OldAmount + amount;
>             String sql = "update shoppingcart set amount = " + NewAmount + " where product_name = '" + product_name + "'&& + email = '" + email + "'";
>             try
>             {
>                 statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public void UpdateProduct(product product)
>         {
>             String AmountSql = "update product SET amount = " + product.getAmount()  + " where product_name = '" + product.getProduct_name() + "'";
>             String brand_nameSql = "update product SET brand_name = '" + product.getBrand_name()  + "' where product_name = '" + product.getProduct_name() + "'";
>             System.out.println(brand_nameSql);
>             String priceSql = "update product SET price = " + product.getPrice()  + " where product_name = '" + product.getProduct_name() + "'";
>             String descriptionSql = "update product SET description = '" + product.getDescription() + "' where product_name = '" + product.getProduct_name() + "'";
>             String type_nameSql = "update product SET type_name = '" + product.getType_name() + "' where product_name = '" + product.getProduct_name() + "'";
>             String sql = "";
>             if(product.getAmount() > 1)
>             {
>                 sql = "update product SET statue = 'available' where product_name = '" + product.getProduct_name() + "'";
>             }
>             else
>             {
>                 sql = "update product SET statue = 'soldOut' where product_name = '" + product.getProduct_name() + "'";
>             }
>             try
>             {
>                 statement.executeUpdate(AmountSql);
>                 statement.executeUpdate(brand_nameSql);
>                 statement.executeUpdate(priceSql);
>                 statement.executeUpdate(descriptionSql);
>                 statement.executeUpdate(type_nameSql);
>                 statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>     }
> 
>     package dao;
>     
>     import bean.product;
>     import bean.user;
>     
>     import java.sql.Connection;
>     import java.sql.SQLException;
>     import java.sql.Statement;
>     
>     public class Update
>     {
>         private Connection connection = Mysql.getMysql().getConnection();
>         private Statement statement = null;
>     
>         public Update()
>         {
>             try
>             {
>                 statement = connection.createStatement();
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>     
>         public int ChangePassword(user u)
>         {
>             int result = 0;
>             int checkId = new select().check(u.getEmail());
>             if(checkId == 1)
>             {
>                 try
>                 {
>                     String sql = "UPDATE users SET pssword '" + u.getPassword() + "' WHERE email='" + u.getEmail() + "'";
>                     result = statement.executeUpdate(sql);
>                 }
>                 catch (SQLException e)
>                 {
>                     throw new RuntimeException(e);
>                 }
>             }
>             return result;
>         }
>     
>         public int delCart(String email)
>         {
>             int result = 0;
>             String DelSql = "DELETE FROM shoppingcart WHERE email = '" + email + "'";
>             int count = 0;
>             try
>             {
>                 count = statement.executeUpdate(DelSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             if (count != 0)
>             {
>                 result = 1;
>             }
>             return result;
>         }
>     
>         public void AddNum(String email,String product_name)
>         {
>     
>             String sql = "update shoppingcart SET amount = " + (new select().getNum(email,product_name) + 1) + " where email = '" + email + "' && product_name = '" + String.format("%s", product_name) + "'";
>             try
>             {
>                 statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public void SubNum(String email,String product_name)
>         {
>             int amount = new select().getNum(email,product_name);
>             String sql = "update shoppingcart SET amount = " + (amount- 1)  + " where email = '" + email + "' && product_name = '" + String.format("%s", product_name) + "'";
>             if(amount > 1)
>             {
>                 try
>                 {
>                     statement.executeUpdate(sql);
>                 }
>                 catch(SQLException e)
>                 {
>                     e.printStackTrace();
>                 }
>             }
>         }
>         public int AddNUM(int num,String product_name)
>         {
>             int count = new select().num(product_name) + num;
>             int result = 0;
>             String sql = "update product set amount = " + count + " where product_name = '" + product_name + "'";
>             try
>             {
>                 result = statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return result;
>         }
>         public int DelProduct(String product_name)
>         {
>             String DelSql = "DELETE FROM product WHERE product_name = '" + product_name + "'";
>             int count = 0;
>             try
>             {
>                 count = statement.executeUpdate(DelSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>         public int DelUser(String email)
>         {
>             String DelSql = "DELETE FROM users WHERE email = '" + email + "'";
>             int count = 0;
>             try
>             {
>                 count = statement.executeUpdate(DelSql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>             return count;
>         }
>         public void addNum(String product_name,int amount,String email)
>         {
>             int OldAmount = new select().getNum(email,product_name);
>             int NewAmount = OldAmount + amount;
>             String sql = "update shoppingcart set amount = " + NewAmount + " where product_name = '" + product_name + "'&& + email = '" + email + "'";
>             try
>             {
>                 statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>         public void UpdateProduct(product product)
>         {
>             String AmountSql = "update product SET amount = " + product.getAmount()  + " where product_name = '" + product.getProduct_name() + "'";
>             String brand_nameSql = "update product SET brand_name = '" + product.getBrand_name()  + "' where product_name = '" + product.getProduct_name() + "'";
>             System.out.println(brand_nameSql);
>             String priceSql = "update product SET price = " + product.getPrice()  + " where product_name = '" + product.getProduct_name() + "'";
>             String descriptionSql = "update product SET description = '" + product.getDescription() + "' where product_name = '" + product.getProduct_name() + "'";
>             String type_nameSql = "update product SET type_name = '" + product.getType_name() + "' where product_name = '" + product.getProduct_name() + "'";
>             String sql = "";
>             if(product.getAmount() > 1)
>             {
>                 sql = "update product SET statue = 'available' where product_name = '" + product.getProduct_name() + "'";
>             }
>             else
>             {
>                 sql = "update product SET statue = 'soldOut' where product_name = '" + product.getProduct_name() + "'";
>             }
>             try
>             {
>                 statement.executeUpdate(AmountSql);
>                 statement.executeUpdate(brand_nameSql);
>                 statement.executeUpdate(priceSql);
>                 statement.executeUpdate(descriptionSql);
>                 statement.executeUpdate(type_nameSql);
>                 statement.executeUpdate(sql);
>             }
>             catch (SQLException e)
>             {
>                 throw new RuntimeException(e);
>             }
>         }
>     }