src/main/java/com/hwua/erhai/dao/impl/UserDaoImpl.java

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

package com.hwua.erhai.dao.impl;

import com.hwua.erhai.dao.IUserDao;
import com.hwua.erhai.entity.Car;
import com.hwua.erhai.entity.User;
import com.hwua.erhai.jdbc.JDBCTemplate;
import com.hwua.erhai.jdbc.PreparedStatementSetter;
import com.hwua.erhai.jdbc.ResultSetHandler;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class UserDaoImpl extends JDBCTemplate implements IUserDao {



    @Override
    public List<User> queryAllUsers() {
        final List<User> list = new ArrayList<>();

        String sql = "SELECT id,username,password," +
                               "sex,id_number,tel,addr,type" +
                               " FROM t_user order by id";
        query(sql, null, new ResultSetHandler() {
            @Override
            public void handleRs(ResultSet rs) throws SQLException {
                while (rs.next()) {
                    User user = new User(
                            rs.getLong(1),
                            rs.getString(2),
                            rs.getString(3),
                            rs.getInt(4),
                            rs.getString(5),
                            rs.getString(6),
                            rs.getString(7),
                            rs.getInt(8));


                    list.add(user);
                }
            }
        });
        return list;
    }

    //通过用户密码和id和类型查询信息
    @Override
    public User queryUser(final String userName, final String password, final int type) {
        final User user = new User();
        String sql = "SELECT id,username,password,"
                + "sex,id_number,tel,addr,type "
                + "FROM t_user WHERE username=? "
                + "AND password=? AND type=?" ;
        query(sql, new PreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement pstmt) throws SQLException {
                pstmt.setString(1, userName);