IGeekShop案例12-实现注册功能和激活功能

你的名字 2024-04-17 14:13 200阅读 0赞

IGeekShop案例12-实现注册功能和激活功能

1WebContent部分

1 register.jsp代码修改

  1. <%@ page language="java" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <!DOCTYPE html>
  4. <html>
  5. <head></head>
  6. <meta name="viewport" content="width=device-width, initial-scale=1">
  7. <title>会员注册</title>
  8. <link rel="stylesheet" href="css/bootstrap.min.css" type="text/css" />
  9. <script src="js/jquery-1.11.3.min.js" type="text/javascript"></script>
  10. <script src="js/bootstrap.min.js" type="text/javascript"></script>
  11. <!-- 引入自定义css文件 style.css -->
  12. <link rel="stylesheet" href="css/style.css" type="text/css" />
  14. <style>
  15. body {
  16.     margin-top: 20px;
  17.     margin: 0 auto;
  18. }
  20. .carousel-inner .item img {
  21.     width: 100%;
  22.     height: 300px;
  23. }
  25. font {
  26.     color: #3164af;
  27.     font-size: 18px;
  28.     font-weight: normal;
  29.     padding: 0 10px;
  30. }
  31. </style>
  32. <script type="text/javascript">
  33.     /* 实现验证码点击改变效果 */
  34.     function changeImge(obj){
  35.         obj.src="${pageContext.request.contextPath }/checkImg?time="+new Date().getTime();
  36.     }
  37. </script>
  40. </head>
  41. <body>
  43.     <!-- 引入header.jsp -->
  44.     <jsp:include page="/header.jsp"></jsp:include>
  46.     <div class="container"
  47.         style="width: 100%; background: url('image/regist_bg.jpg');">
  48.         <div class="row">
  49.             <div class="col-md-2"></div>
  50.             <div class="col-md-8"
  51.                 style="background: #fff; padding: 40px 80px; margin: 30px; border: 7px solid #ccc;">
  52.                 <font>会员注册</font>USER REGISTER
  53.                 <form class="form-horizontal"  action="${pageContext.request.contextPath }/register" method="post" style="margin-top: 5px;">
  54.                     <div class="form-group">
  55.                         <label for="username" class="col-sm-2 control-label">用户名</label>
  56.                         <div class="col-sm-6">
  57.                             <input type="text" class="form-control" id="username" name="username"
  58.                                 placeholder="请输入用户名">
  59.                         </div>
  60.                     </div>
  61.                     <div class="form-group">
  62.                         <label for="inputPassword3" class="col-sm-2 control-label">密码</label>
  63.                         <div class="col-sm-6">
  64.                             <input type="password" class="form-control" id="inputPassword3" name="password"
  65.                                 placeholder="请输入密码">
  66.                         </div>
  67.                     </div>
  68.                     <div class="form-group">
  69.                         <label for="confirmpwd" class="col-sm-2 control-label">确认密码</label>
  70.                         <div class="col-sm-6">
  71.                             <input type="password" class="form-control" id="confirmpwd"
  72.                                 placeholder="请输入确认密码">
  73.                         </div>
  74.                     </div>
  75.                     <div class="form-group">
  76.                         <label for="inputEmail3" class="col-sm-2 control-label">Email</label>
  77.                         <div class="col-sm-6">
  78.                             <input type="email" class="form-control" id="inputEmail3" name="email"
  79.                                 placeholder="Email">
  80.                         </div>
  81.                     </div>
  82.                     <div class="form-group">
  83.                         <label for="usercaption" class="col-sm-2 control-label">姓名</label>
  84.                         <div class="col-sm-6">
  85.                             <input type="text" class="form-control" id="usercaption" name="name"
  86.                                 placeholder="请输入姓名">
  87.                         </div>
  88.                     </div>
  89.                     <div class="form-group opt">
  90.                         <label for="inlineRadio1" class="col-sm-2 control-label">性别</label>
  91.                         <div class="col-sm-6">
  92.                             <label class="radio-inline"> <input type="radio"
  93.                                 name="sex" id="sex1" value="male">男
  94.                             </label> <label class="radio-inline"> <input type="radio"
  95.                                 name="sex" id="sex2" value="female">女
  96.                             </label>
  97.                         </div>
  98.                     </div>
  99.                     <div class="form-group">
  100.                         <label for="date" class="col-sm-2 control-label">出生日期</label>
  101.                         <div class="col-sm-6">
  102.                             <input type="date" class="form-control" name="birthday"> 
  103.                         </div>
  104.                     </div>
  106.                     <div class="form-group">
  107.                         <label for="date" class="col-sm-2 control-label">验证码</label>
  108.                         <div class="col-sm-3">
  109.                             <input type="text" class="form-control" name="checkCode">
  110.                         </div>
  111.                         <div class="col-sm-2">
  112.                             <img src="${pageContext.request.contextPath }/checkImg" onclick="changeImge(this)"/>
  113.                         </div>
  114.                     </div>
  116.                     <div class="form-group">
  117.                         <div class="col-sm-offset-2 col-sm-10">
  118.                             <input type="submit" width="100" value="注册" name="submit"
  119.                                 style="background: url('./images/register.gif') no-repeat scroll 0 0 rgba(0, 0, 0, 0); height: 35px; width: 100px; color: white;">
  120.                             <div>${registInfo }</div>
  121.                         </div>
  122.                     </div>
  123.                 </form>
  124.             </div>
  126.             <div class="col-md-2"></div>
  128.         </div>
  129.     </div>
  131.     <!-- 引入footer.jsp -->
  132.     <jsp:include page="/footer.jsp"></jsp:include>
  134. </body>
  135. </html>

2 registerFail.jsp代码

  1. <%@ page language="java" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
  4. <html>
  5. <head>
  6. <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
  7. <title>Insert title here</title>
  8. </head>
  9. <body>
  10.     <h2>对不起，注册失败，请联系管理员 010-68888888</h2>
  11. </body>
  12. </html>

3 registerSuccess.jsp代码

  1. <%@ page language="java" contentType="text/html; charset=UTF-8"
  2.     pageEncoding="UTF-8"%>
  3. <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
  4. <html>
  5. <head>
  6. <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
  7. <title>Insert title here</title>
  8. </head>
  9. <body>
  10.     <h2>恭喜您注册成功，请赶快前往注册邮箱激活您的帐户</h2>
  11.     <div>
  12.         <span><a href="http://mail.163.com/">网易163邮箱</a></span>   
  13.         <span><a href="http://mail.126.com/">网易126邮箱</a></span>   
  14.         <span><a href="https://mail.qq.com/cgi-bin/loginpage">腾讯QQ邮箱</a></span>   
  15.     </div>
  16. </body>
  17. </html>

2 web层

1RegisterServlet代码

注意自动映射封装的时候，如何进行类型的转换。如String 转换成date类型。本例中获取到的birthday需要转成date类型。

  1. package www.test.web.servlet;
  3. import java.io.IOException;
  4. import java.lang.reflect.InvocationTargetException;
  5. import java.sql.SQLException;
  6. import java.text.ParseException;
  7. import java.text.SimpleDateFormat;
  8. import java.util.Date;
  9. import java.util.Map;
  11. import javax.mail.MessagingException;
  12. import javax.servlet.ServletException;
  13. import javax.servlet.http.HttpServlet;
  14. import javax.servlet.http.HttpServletRequest;
  15. import javax.servlet.http.HttpServletResponse;
  17. import org.apache.commons.beanutils.BeanUtils;
  18. import org.apache.commons.beanutils.ConvertUtils;
  19. import org.apache.commons.beanutils.Converter;
  21. import www.test.domain.User;
  22. import www.test.service.UserService;
  23. import www.test.utils.CommonsUtils;
  24. import www.test.utils.MailUtils;
  26. public class RegisterServlet extends HttpServlet {
  28.     public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  30.         // 解决乱码问题
  31.         request.setCharacterEncoding("UTF-8");
  33.         // 判断验证码是否正确
  34.         // 获得页面输入的验证
  35.         String checkCode_client = request.getParameter("checkCode");
  36.         // 获得生成图片的文字的验证码
  37.         String checkCode_session = (String) request.getSession().getAttribute("checkcode_session");
  38.         // 比对页面的和生成图片的文字的验证码是否一致
  39.         if (!checkCode_session.equals(checkCode_client)) {
  40.             request.setAttribute("registInfo", "您的验证码不正确");
  41.             request.getRequestDispatcher("/register.jsp").forward(request, response);
  42.             return; // 验证码输入错误的话，就没有必要获取输入的用户名和密码等其他信息
  43.         }
  45.         // 获得表单数据
  46.         Map<String, String[]> properties = request.getParameterMap();
  47.         User user = new User();
  48.         try {
  49.             // 自己指定一个类型转换器（将String转成Date）
  50.             // ConvertUtils.register(converter, clazz);
  51.             // converter : 转换器接口 clazz:要转换成的类型
  52.             ConvertUtils.register(new Converter() {
  54.                 @Override
  55.                 // value要转换的值
  56.                 public Object convert(Class clazz, Object value) {
  57.                     // 将string转成date
  58.                     SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
  59.                     Date date = null;
  60.                     try {
  61.                         date = dateFormat.parse(value.toString());
  62.                     } catch (ParseException e) {
  63.                         e.printStackTrace();
  64.                     }
  65.                     return date;
  66.                 }
  67.             }, Date.class);
  69.             // 进行映射封装
  70.             BeanUtils.populate(user, properties);
  71.         } catch (IllegalAccessException | InvocationTargetException e) {
  73.             e.printStackTrace();
  74.         }
  76.         // 到这里user就封装了
  77.         // 下面手动封装剩余的项
  78.         // private String uid;
  79.         user.setUid(CommonsUtils.getUUID());
  80.         // private String telephone;
  81.         user.setTelephone(null);
  82.         // private int state;//是否激活
  83.         user.setState(0);
  84.         // private String code;//激活码
  85.         String activeCode = CommonsUtils.getUUID();
  86.         user.setCode(activeCode);
  88.         // 将user传递给service层
  89.         UserService service = new UserService();
  90.         boolean isRegisterSuccess =true;
  91.         try {
  92.             isRegisterSuccess = service.regist(user);
  93.         } catch (SQLException e) {
  94.             e.printStackTrace();
  95.         }
  97.         //是否注册成功
  98.         if(isRegisterSuccess){
  99.             //发送激活邮件
  100.             String emailMsg = "恭喜您注册成功，请点击下面的连接进行激活账户"
  101.                     +"<a href='http://localhost:8080/WEBTestShop28/active?activeCode="+activeCode+"'>"
  102.                             + "http://localhost:8080/WEBTestShop28/active?activeCode="+activeCode+"</a>";
  103.             String subject = "激活邮件";
  105.             try {
  106.                 MailUtils.sendMail(user.getEmail(), subject, emailMsg);
  107.             } catch (MessagingException e) {
  109.                 e.printStackTrace();
  110.             }
  112.             //跳转到注册成功页面
  113.             response.sendRedirect(request.getContextPath()+"/registerSuccess.jsp");
  114.         }else{
  115.             //跳转到失败的提示页面
  116.             response.sendRedirect(request.getContextPath()+"/registerFail.jsp");
  117.         }
  118.     }
  120.     public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  121.         doGet(request, response);
  122.     }
  124. }

2 ActiveServlet代码

  1. package www.test.web.servlet;
  3. import java.io.IOException;
  4. import java.sql.SQLException;
  6. import javax.servlet.ServletException;
  7. import javax.servlet.http.HttpServlet;
  8. import javax.servlet.http.HttpServletRequest;
  9. import javax.servlet.http.HttpServletResponse;
  11. import www.test.service.UserService;
  13. public class ActiveServlet extends HttpServlet {
  15.     public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  17.         //获得激活码
  18.         String activeCode = request.getParameter("activeCode");
  20.         //将获取到的激活码传递给service层
  21.         UserService service = new UserService();
  22.         boolean isActiveSuccess = true;
  23.         try {
  24.             isActiveSuccess = service.active(activeCode);
  25.         } catch (SQLException e) {
  27.             e.printStackTrace();
  28.         }
  30.         if(isActiveSuccess){
  31.             //激活成功跳转到登录页面
  32.             response.sendRedirect(request.getContextPath()+"/login.jsp");
  33.         }else{ //激活失败跳转到注册页面
  34.             response.sendRedirect(request.getContextPath()+"/register.jsp");
  35.         }
  36.     }
  38.     public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
  39.         doGet(request, response);
  40.     }
  42. }

3 CheckImgServlet代码

  1. package www.test.web.servlet;
  3. import java.awt.Color;
  4. import java.awt.Font;
  5. import java.awt.Graphics;
  6. import java.awt.Graphics2D;
  7. import java.awt.image.BufferedImage;
  8. import java.io.BufferedReader;
  9. import java.io.FileReader;
  10. import java.io.IOException;
  11. import java.util.ArrayList;
  12. import java.util.List;
  13. import java.util.Random;
  15. import javax.imageio.ImageIO;
  16. import javax.servlet.ServletException;
  17. import javax.servlet.http.HttpServlet;
  18. import javax.servlet.http.HttpServletRequest;
  19. import javax.servlet.http.HttpServletResponse;
  21. /**
  22.  * 验证码生成程序
  23.  */
  24. public class CheckImgServlet extends HttpServlet {
  26.     // 集合中保存所有成语
  27.     private List<String> words = new ArrayList<String>();
  29.     @Override
  30.     public void init() throws ServletException {
  31.         // 初始化阶段，读取new_words.txt
  32.         // web工程中读取文件，必须使用绝对磁盘路径
  33.         String path = getServletContext().getRealPath("/WEB-INF/new_words.txt");
  34.         try {
  35.             BufferedReader reader = new BufferedReader(new FileReader(path));
  36.             String line;
  37.             while ((line = reader.readLine()) != null) {
  38.                 words.add(line);
  39.             }
  40.             reader.close();
  41.         } catch (IOException e) {
  42.             e.printStackTrace();
  43.         }
  44.     }
  46.     public void doGet(HttpServletRequest request, HttpServletResponse response)
  47.             throws ServletException, IOException {
  48.         // 禁止缓存
  49.         // response.setHeader("Cache-Control", "no-cache");
  50.         // response.setHeader("Pragma", "no-cache");
  51.         // response.setDateHeader("Expires", -1);
  53.         int width = 120;
  54.         int height = 30;
  56.         // 步骤一 绘制一张内存中图片
  57.         BufferedImage bufferedImage = new BufferedImage(width, height,
  58.                 BufferedImage.TYPE_INT_RGB);
  60.         // 步骤二 图片绘制背景颜色 ---通过绘图对象
  61.         Graphics graphics = bufferedImage.getGraphics();// 得到画图对象 --- 画笔
  62.         // 绘制任何图形之前 都必须指定一个颜色
  63.         graphics.setColor(getRandColor(200, 250));
  64.         graphics.fillRect(0, 0, width, height);
  66.         // 步骤三 绘制边框
  67.         graphics.setColor(Color.WHITE);
  68.         graphics.drawRect(0, 0, width - 1, height - 1);
  70.         // 步骤四 四个随机数字
  71.         Graphics2D graphics2d = (Graphics2D) graphics;
  72.         // 设置输出字体
  73.         graphics2d.setFont(new Font("宋体", Font.BOLD, 18));
  75.         Random random = new Random();// 生成随机数
  76.         int index = random.nextInt(words.size());
  77.         String word = words.get(index);// 获得成语
  79.         // 定义x坐标
  80.         int x = 10;
  81.         for (int i = 0; i < word.length(); i++) {
  82.             // 随机颜色
  83.             graphics2d.setColor(new Color(20 + random.nextInt(110), 20 + random
  84.                     .nextInt(110), 20 + random.nextInt(110)));
  85.             // 旋转 -30 --- 30度
  86.             int jiaodu = random.nextInt(60) - 30;
  87.             // 换算弧度
  88.             double theta = jiaodu * Math.PI / 180;
  90.             // 获得字母数字
  91.             char c = word.charAt(i);
  93.             // 将c 输出到图片
  94.             graphics2d.rotate(theta, x, 20);
  95.             graphics2d.drawString(String.valueOf(c), x, 20);
  96.             graphics2d.rotate(-theta, x, 20);
  97.             x += 30;
  98.         }
  99.         // 将验证码内容保存session
  100.         request.getSession().setAttribute("checkcode_session", word);
  102.         // 步骤五 绘制干扰线
  103.         graphics.setColor(getRandColor(160, 200));
  104.         int x1;
  105.         int x2;
  106.         int y1;
  107.         int y2;
  108.         for (int i = 0; i < 30; i++) {
  109.             x1 = random.nextInt(width);
  110.             x2 = random.nextInt(12);
  111.             y1 = random.nextInt(height);
  112.             y2 = random.nextInt(12);
  113.             graphics.drawLine(x1, y1, x1 + x2, x2 + y2);
  114.         }
  116.         // 将上面图片输出到浏览器 ImageIO
  117.         graphics.dispose();// 释放资源
  119.         //将图片写到response.getOutputStream()中
  120.         ImageIO.write(bufferedImage, "jpg", response.getOutputStream());
  122.     }
  124.     public void doPost(HttpServletRequest request, HttpServletResponse response)
  125.             throws ServletException, IOException {
  126.         doGet(request, response);
  127.     }
  129.     /**
  130.      * 取其某一范围的color
  131.      * 
  132.      * @param fc
  133.      *            int 范围参数1
  134.      * @param bc
  135.      *            int 范围参数2
  136.      * @return Color
  137.      */
  138.     private Color getRandColor(int fc, int bc) {
  139.         // 取其随机颜色
  140.         Random random = new Random();
  141.         if (fc > 255) {
  142.             fc = 255;
  143.         }
  144.         if (bc > 255) {
  145.             bc = 255;
  146.         }
  147.         int r = fc + random.nextInt(bc - fc);
  148.         int g = fc + random.nextInt(bc - fc);
  149.         int b = fc + random.nextInt(bc - fc);
  150.         return new Color(r, g, b);
  151.     }
  153. }

3 service层

  1. package www.test.service;
  3. import java.sql.SQLException;
  5. import www.test.dao.UserDao;
  6. import www.test.domain.User;
  8. public class UserService {
  9.     //注冊
  10.     public boolean regist(User user) throws SQLException {
  11.         UserDao dao = new UserDao();
  12.         int row = dao.regist(user);
  13.         return row>0?true:false;
  14.     }
  16.     //激活
  17.     public boolean active(String activeCode) throws SQLException {
  18.         UserDao dao = new UserDao();
  19.         int row = dao.active(activeCode);
  20.         return row>0?true:false;
  21.     }
  23. }

4 dao层代码

  1. package www.test.dao;
  3. import java.sql.SQLException;
  5. import org.apache.commons.dbutils.QueryRunner;
  7. import www.test.domain.User;
  8. import www.test.utils.C3P0Utils;
  10. public class UserDao {
  12.     //注冊
  13.     public int regist(User user) throws SQLException {
  14.         QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
  15.         String sql ="insert into user values (?,?,?,?,?,?,?,?,?,?);";
  16.         int row = qr.update(sql, user.getUid(),user.getUsername(),user.getPassword(),
  17.                 user.getName(),user.getEmail(),user.getTelephone(),
  18.                 user.getBirthday(),user.getSex(),user.getState(),user.getCode());
  19.         return row;
  20.     }
  22.     //激活
  23.     public int active(String activeCode) throws SQLException {
  24.         QueryRunner qr = new QueryRunner(C3P0Utils.getDataSource());
  25.         String sql ="update user set state=? where code=?";
  26.         int row = qr.update(sql, 1,activeCode);
  27.         return row;
  28.     }
  30. }

5 utils部分

1 CommonsUtils代码

  1. package www.test.utils;
  3. import java.util.UUID;
  5. public class CommonsUtils {
  7.     public static String getUUID(){
  8.         return UUID.randomUUID().toString().replaceAll("-", "");
  9.     }
  10. }

2 MD5Utils代码

  1. package www.test.utils;
  3. import java.math.BigInteger;
  4. import java.security.MessageDigest;
  5. import java.security.NoSuchAlgorithmException;
  7. public class MD5Utils {
  8.     /**
  9.      * 使用md5的算法进行加密
  10.      */
  11.     public static String md5(String plainText) {
  12.         byte[] secretBytes = null;
  13.         try {
  14.             secretBytes = MessageDigest.getInstance("md5").digest(plainText.getBytes());
  15.         } catch (NoSuchAlgorithmException e) {
  16.             throw new RuntimeException("没有md5这个算法！");
  17.         }
  18.         String md5code = new BigInteger(1, secretBytes).toString(16);// 16进制数字
  19.         // 如果生成数字未满32位，需要前面补0
  20.         for (int i = 0; i < 32 - md5code.length(); i++) {
  21.             md5code = "0" + md5code;
  22.         }
  23.         return md5code;
  24.     }
  26.     public static void main(String[] args) {
  27.         System.out.println(md5("123"));
  28.     }
  30. }

3 MailUtils代码

  1. package www.test.utils;
  3. import java.security.GeneralSecurityException;
  4. import java.util.Properties;
  6. import javax.mail.Authenticator;
  7. import javax.mail.Message;
  8. import javax.mail.MessagingException;
  9. import javax.mail.PasswordAuthentication;
  10. import javax.mail.Session;
  11. import javax.mail.Transport;
  12. import javax.mail.internet.AddressException;
  13. import javax.mail.internet.InternetAddress;
  14. import javax.mail.internet.MimeMessage;
  15. import javax.mail.internet.MimeMessage.RecipientType;
  17. import com.sun.mail.util.MailSSLSocketFactory;
  19. public class MailUtils {
  21.     //email:邮件发给谁  subject:主题  emailMsg：邮件的内容
  22.     public static void sendMail(String email, String subject, String emailMsg)
  23.             throws AddressException, MessagingException {
  25.         // 1.创建一个程序与邮件服务器会话对象 Session
  26.         Properties props = new Properties();
  27.         props.setProperty("mail.transport.protocol", "SMTP");//发邮件的协议
  28.         props.setProperty("mail.host", "smtp.126.com");//发送邮件的服务器地址
  29.         props.setProperty("mail.smtp.auth", "true");// 指定验证为true
  31.         //开启SSL加密  ,QQ邮箱必须开启ssl加密才可以。
  32.         MailSSLSocketFactory sf = null;
  33.         try {
  34.             sf = new MailSSLSocketFactory();
  35.         } catch (GeneralSecurityException e) {
  37.             e.printStackTrace();
  38.         }
  39.         sf.setTrustAllHosts(true);
  40.         props.put("mail.smtp.ssl.enable", "true");
  41.         props.put("mail.smtp.ssl.socketFactory", sf);
  43.         // 创建验证器
  44.         Authenticator auth = new Authenticator() {
  45.             public PasswordAuthentication getPasswordAuthentication() {
  46.                 return new PasswordAuthentication("luojun281", "123456ljp");//发邮件的账号的验证 12345为授权码，并非密码
  47.             }
  48.         };
  50.         //这个是邮箱服务器的session 和之前学的session不是同一个session
  51.         Session session = Session.getInstance(props, auth);
  53.         // 2.创建一个Message，它相当于是邮件内容
  54.         Message message = new MimeMessage(session);
  56.         message.setFrom(new InternetAddress("luojun281@126.com")); // 设置发送者
  58.         message.setRecipient(RecipientType.TO, new InternetAddress(email)); // 设置发送方式与接收者
  60.         message.setSubject(subject);//邮件的主题
  62.         message.setContent(emailMsg, "text/html;charset=utf-8");
  64.         // 3.创建 Transport用于将邮件发送
  65.         Transport.send(message);
  66.     }
  67. }

4 c3p0utils代码

  1. package www.test.utils;
  3. import java.sql.Connection;
  4. import java.sql.ResultSet;
  5. import java.sql.SQLException;
  6. import java.sql.Statement;
  8. import javax.sql.DataSource;
  10. import com.mchange.v2.c3p0.ComboPooledDataSource;
  12. public class C3P0Utils {
  14.     // 1 获得Connection ----- 从连接池中获取
  15.     private static DataSource dataSource = new ComboPooledDataSource();
  17.     // 2 创建ThreadLocal 存储的类型是Connection
  18.     private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
  20.     // 3 直接可以获取一个连接池
  21.     public static DataSource getDataSource() {
  22.         return dataSource;
  23.     }
  25.     // 4 直接获取一个连接
  26.     public static Connection getConnection() throws SQLException {
  27.         return dataSource.getConnection();
  28.     }
  30.     // 5 获取绑定到ThreadLocal上的连接对象
  31.     public static Connection getCurrentConnection() throws SQLException {
  32.         //从ThreadLocal寻找 当前线程是否有对应Connection
  33.         Connection con = tl.get();
  34.         if (con == null) {
  35.             //获得新的connection
  36.             con = dataSource.getConnection();
  37.             //将conn资源绑定到ThreadLocal（map）上
  38.             tl.set(con);
  39.         }
  40.         return con;
  41.     }
  43.     // 6 开启事务
  44.     public static void startTransaction() throws SQLException {
  45.         Connection con = getCurrentConnection();
  46.         if (con != null) {
  47.             con.setAutoCommit(false);
  48.         }
  49.     }
  51.     // 7 事务回滚
  52.     public static void rollback() throws SQLException {
  53.         Connection con = getCurrentConnection();
  54.         if (con != null) {
  55.             con.rollback();
  56.         }
  57.     }
  59.     //  8 提交并且 关闭资源及从ThreadLocall中释放
  60.     public static void commitAndRelease() throws SQLException {
  61.         Connection con = getCurrentConnection();
  62.         if (con != null) {
  63.             con.commit(); // 事务提交
  64.             con.close();// 关闭资源
  65.             tl.remove();// 从线程绑定中移除
  66.         }
  67.     }
  69.     // 9 关闭资源方法
  70.     public static void close(ResultSet rs, Statement st, Connection con) throws SQLException {
  71.         if (rs != null) {
  72.             rs.close();
  73.         }
  74.         if (st != null) {
  75.             st.close();
  76.         }
  77.         if (con != null) {
  78.             con.close();
  79.         }
  80.     }
  81. }

6 domain部分

1 user类

  1. package www.test.domain;
  3. import java.util.Date;
  5. public class User {
  7.      /*`uid` varchar(32) NOT NULL,
  8.       `username` varchar(20) DEFAULT NULL,
  9.       `password` varchar(20) DEFAULT NULL,
  10.       `name` varchar(20) DEFAULT NULL,
  11.       `email` varchar(30) DEFAULT NULL,
  12.       `telephone` varchar(20) DEFAULT NULL,
  13.       `birthday` date DEFAULT NULL,
  14.       `sex` varchar(10) DEFAULT NULL,
  15.       `state` int(11) DEFAULT NULL,
  16.       `code` varchar(64) DEFAULT NULL,*/
  18.     private String uid;
  19.     private String username;
  20.     private String password;
  21.     private String name;
  22.     private String email;
  23.     private String telephone;
  24.     private Date birthday;
  25.     private String sex;
  26.     private int state;//是否激活
  27.     private String code;//激活码
  29.     public String getUid() {
  30.         return uid;
  31.     }
  32.     public void setUid(String uid) {
  33.         this.uid = uid;
  34.     }
  35.     public String getUsername() {
  36.         return username;
  37.     }
  38.     public void setUsername(String username) {
  39.         this.username = username;
  40.     }
  41.     public String getPassword() {
  42.         return password;
  43.     }
  44.     public void setPassword(String password) {
  45.         this.password = password;
  46.     }
  47.     public String getName() {
  48.         return name;
  49.     }
  50.     public void setName(String name) {
  51.         this.name = name;
  52.     }
  53.     public String getEmail() {
  54.         return email;
  55.     }
  56.     public void setEmail(String email) {
  57.         this.email = email;
  58.     }
  59.     public String getTelephone() {
  60.         return telephone;
  61.     }
  62.     public void setTelephone(String telephone) {
  63.         this.telephone = telephone;
  64.     }
  65.     public Date getBirthday() {
  66.         return birthday;
  67.     }
  68.     public void setBirthday(Date birthday) {
  69.         this.birthday = birthday;
  70.     }
  71.     public String getSex() {
  72.         return sex;
  73.     }
  74.     public void setSex(String sex) {
  75.         this.sex = sex;
  76.     }
  77.     public int getState() {
  78.         return state;
  79.     }
  80.     public void setState(int state) {
  81.         this.state = state;
  82.     }
  83.     public String getCode() {
  84.         return code;
  85.     }
  86.     public void setCode(String code) {
  87.         this.code = code;
  88.     }
  89. }

发表评论

表情：
评论列表 （有 0 条评论，200人围观）

还没有评论，来说两句吧...

相关阅读