ADD file via upload

AccountzzyDaoImp.java

@@ -0,0 +1,79 @@
+package com.zzy.dao.mysql;
+
+import com.zzy.dao.AccountzzyDao;
+import com.zzy.domain.Accountzzy;
+
+import java.sql.*;
+import java.util.ArrayList;
+import java.util.List;
+
+import static com.zzy.dao.mysql.DBHelper.url;
+
+public class AccountzzyDaoImp implements AccountzzyDao {
+    @Override
+    public List<Accountzzy> findAll() {
+        ArrayList<Accountzzy> accountzzy = new ArrayList<Accountzzy>();
+        try {
+            Class.forName("com.mysql.cj.jdbc.Driver");
+//            String url="jdbc:mysql://localhost:3306/food?userSSL=false&serverTimezone=Asia/Shanghai";
+            String user = "root";
+            String password ="159357";
+
+            Connection conn= DriverManager.getConnection(url,user,password);
+            String sql ="select *from users";
+            Statement sts =conn.createStatement();
+            ResultSet rs=sts.executeQuery(sql);
+
+            while(rs.next()) {
+                Accountzzy account1 =new Accountzzy();
+                ((Accountzzy) account1).setUserid(((ResultSet) rs).getString("userid"));
+                account1.setUsername(rs.getString("username"));
+                account1.setAddress(rs.getString("address"));
+                account1.setPhone(rs.getString("phone"));
+                account1.setPassword(rs.getString("password"));
+                account1.add(account1);
+
+            }
+            rs.close();
+            sts.close();
+            conn.close();
+        }catch (Exception e) {
+            e.printStackTrace();
+        }
+        return accountzzy;
+    }
+
+
+    @Override
+    public Accountzzy findById(String userid) {
+        Accountzzy account = null;
+        try (java.sql.Connection connection = DBHelper.getConnection(); // 假设DBHelper类有getConnection方法
+             PreparedStatement pstmt = connection.prepareStatement("select * from users where userid = ?")) {
+
+            pstmt.setString(1, userid); // 设置参数
+            try (ResultSet rs = pstmt.executeQuery()) {
+                if (rs.next()) {
+                    account = new Accountzzy();
+                    // 类似地从rs中设置account的属性
+                }
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+        return account;
+    }
+        @Override
+    public int create(Accountzzy accountzzy) {
+        return 0;
+    }
+
+    @Override
+    public int modify(Accountzzy accountzzy) {
+        return 0;
+    }
+
+    @Override
+    public int remove(Accountzzy accountzzy) {
+        return 0;
+    }
+}