1. package com.xf.dao;
    3. import com.xf.beans.UserInfo;
    4. import com.xf.utils.DBManager;
    5. import org.apache.commons.dbutils.QueryRunner;
    6. import org.apache.commons.dbutils.handlers.BeanHandler;
    8. import java.sql.Connection;
    9. import java.sql.SQLException;
    11. //对用户进行CRUD操作，增删改查
    12. public class UserDao {
    14.     QueryRunner qr = new QueryRunner();//进行crud操作
    16.     //登陆实现：通过用户输入对用户名与密码，对数据库数据进行查询，如果次用户名与密码查询到用户代表登陆成功，如果没有查询到用户，代表登陆失败
    17.     //登陆功能,返回用户对象
    18.     public UserInfo login(String username,String password){
    19.         //通过工具类去获取数据库连接
    20.         Connection conn = DBManager.getConn();
    21.         //qr执行查询连接 sql语句
    22.         try {
    23.           return  qr.query(conn,"select * from userinfo where id=? and loginpwd=?",new BeanHandler<>(UserInfo.class),username,password);
    24.         } catch (SQLException e) {
    25.             e.printStackTrace();
    26.         }finally {
    27.             try {
    28.                 conn.close();
    29.             } catch (SQLException e) {
    30.                 e.printStackTrace();
    31.             }
    32.         }
    34.         return null;
    35.     }
    37.     //注册功能,昵称，密码
    38.     public int register(String nickName,String password){
    39.         Connection conn = DBManager.getConn();
    40.         try {
    41.             int count = qr.execute(conn,"insert into userinfo (nickname,loginpwd,age) values (?,?,?)",nickName,password,18);
    42.             return count;
    43.         } catch (SQLException e) {
    44.             e.printStackTrace();
    45.         }
    46.         return 0;
    47.     }
    48.     //获取最后注册到到用户信息
    49.     public UserInfo getRegisterUser(){
    50.         //通过工具类去获取数据库连接
    51.         Connection conn = DBManager.getConn();
    52.         //qr执行查询连接 sql语句
    53.         try {
    54.             return  qr.query(conn,"select * from userinfo order by id desc LIMIT 1 ",new BeanHandler<>(UserInfo.class));
    55.         } catch (SQLException e) {
    56.             e.printStackTrace();
    57.         }finally {
    58.             try {
    59.                 conn.close();
    60.             } catch (SQLException e) {
    61.                 e.printStackTrace();
    62.             }
    63.         }
    64.         return null;
    65.     }
    67.     public static void main(String[] args) {
    68.         UserDao userDao =new UserDao();
    69.         //System.out.println(userDao.login("10001","520520"));
    70.         userDao.register("小甜甜","111111");
    71.     }
    72. }