项目01-JavaWeb网上书城01之工具类

1.项目中用到的小工具

1.CommonUtils

　　CommonUtils类就两个方法：

　　　　1.String uuid()：生成长度32的随机字符，通常用来做实体类的ID。底层使用了UUID类完成；

　　　　2.T toBean(Map, Class<T>)：把Map转换成指定类型的Bean对象。通常用来获取表单数据（request.getParameterMap()）封装到JavaBean中，底层使用了common-beanutils。注意，本方法要求map中键的名称要与Bean的属性名称相同才能完成映射，否则不能完成映射；

　　1.源码

import java.util.Map;
import java.util.UUID;

import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.beanutils.ConvertUtils;

/**
 * 小工具
 * 10  *
 */
public class CommonUtils {
    /**
     * 返回一个不重复的字符串
     * @return
     */
    public static String uuid() {
        return UUID.randomUUID().toString().replace("-", "").toUpperCase();
    }

    /**
     * 把map转换成对象
     * @param map
     * @param clazz
     * @return
     * 
     * 把Map转换成指定类型
     */
    @SuppressWarnings("rawtypes")
    public static <T> T toBean(Map map, Class<T> clazz) {
        try {
            /*
             * 1. 通过参数clazz创建实例
             * 2. 使用BeanUtils.populate把map的数据封闭到bean中
             */
            T bean = clazz.newInstance();
            ConvertUtils.register(new DateConverter(), java.util.Date.class);
            BeanUtils.populate(bean, map);
            return bean;
        } catch(Exception e) {
            throw new RuntimeException(e);
        }
    }
}

　　2.测试代码

    /**
     * 随机生成32位长的字符串，通常用来做实体类的ID
     */
    @Test
    public void testUuid() {
        String s = CommonUtils.uuid();//生成随机32位长的字符串
        System.out.println(s);
    }
    
    /**
     * 把Map类型映射成Bean类型。
     * 要求map中键的名称与Person类的属性名称相同。
     * 即map的key分别为：pid、name、age、birthday，person的属性名称也是pid、name、age、birthday
     */
    @Test
    public void testToBean() {
        Map<String,String> map = new HashMap<String,String>();
        /*
         * map的key：pid、age、birthday、myname
         * person的属性：pid、age、birthday、name
         * map中没有名为name的键值，而多出一个名为myname的键值，所以映射后的person对象的name属性值为null。
         * map中的age和birthday都是字符串类型，而person的age是int类型、birthday是Date类型，但toBean()方法会自动对Map中值进行类型转换。
         */
        map.put("pid", CommonUtils.uuid());
        map.put("age", "23");
        map.put("birthday", "2014-01-30");
        map.put("myname", "张三");
        
        Person p = CommonUtils.toBean(map, Person.class);
        System.out.println(p);
    }

=========================================================================================================================================

2.JdbcUtils

JdbcUtils用来获取Connection对象，以及开启和关闭事务。

　　l  Connection getConnection()：从c3p0连接池获取Connection对象，所以需要提供c3p0-config.xml配置文件；

　　l  beginTransaction()：为当前线程开启事务；

　　l  commitTransaction()：提交当前线程的事务；

　　l  rollbackTransaction()：回滚当前线程的事务；

　　l  releaseConnection(Connection)：如果参数连接对象不是当前事务的连接对象，那么关闭它，否则什么都不做；

　　1.源码

package cn.itcast.jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import javax.sql.DataSource;

import com.mchange.v2.c3p0.ComboPooledDataSource;

/**
 * 使用本类的方法，必须提供c3p0-copnfig.xml文件
 * @author qdmmy6
 */
public class JdbcUtils {
    // 饿汉式
    private static DataSource ds = new ComboPooledDataSource();
    
    /**
     * 它为null表示没有事务
     * 它不为null表示有事务
     * 当开启事务时，需要给它赋值
     * 当结束事务时，需要给它赋值为null
     * 并且在开启事务时，让dao的多个方法共享这个Connection
     */
    private static ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
    
    public static DataSource getDataSource() {
        return ds;
    }
    
    /**
     * dao使用本方法来获取连接
     * @return
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException {
        /*
         * 如果有事务，返回当前事务的con
         * 如果没有事务，通过连接池返回新的con
         */
        Connection con = tl.get();//获取当前线程的事务连接
        if(con != null) return con;
        return ds.getConnection();
    }
    
    /**
     * 开启事务
     * @throws SQLException 
     */
    public static void beginTransaction() throws SQLException {
        Connection con = tl.get();//获取当前线程的事务连接
        if(con != null) throw new SQLException("已经开启了事务，不能重复开启！");
        con = ds.getConnection();//给con赋值，表示开启了事务
        con.setAutoCommit(false);//设置为手动提交
        tl.set(con);//把当前事务连接放到tl中
    }
    
    /**
     * 提交事务
     * @throws SQLException 
     */
    public static void commitTransaction() throws SQLException {
        Connection con = tl.get();//获取当前线程的事务连接
        if(con == null) throw new SQLException("没有事务不能提交！");
        con.commit();//提交事务
        con.close();//关闭连接
        con = null;//表示事务结束！
        tl.remove();
    }
    
    /**
     * 回滚事务
     * @throws SQLException 
     */
    public static void rollbackTransaction() throws SQLException {
        Connection con = tl.get();//获取当前线程的事务连接
        if(con == null) throw new SQLException("没有事务不能回滚！");
        con.rollback();
        con.close();
        con = null;
        tl.remove();
    }
    
    /**
     * 释放Connection
     * @param con
     * @throws SQLException 
     */
    public static void releaseConnection(Connection connection) throws SQLException {
        Connection con = tl.get();//获取当前线程的事务连接
        if(connection != con) {//如果参数连接，与当前事务连接不同，说明这个连接不是当前事务，可以关闭！
            if(connection != null &&!connection.isClosed()) {//如果参数连接没有关闭，关闭之！
                connection.close();
            }
        }
    }
}

　

　2.测试代码

c3p0-config.xml

<?xml version="1.0" encoding="UTF-8" ?>
<c3p0-config>
    <default-config> 
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb1</property>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="user">root</property>
        <property name="password">root</property>
 
        <property name="acquireIncrement">3</property>
        <property name="initialPoolSize">10</property>
        <property name="minPoolSize">2</property>
        <property name="maxPoolSize">10</property>
    </default-config>
</c3p0-config>

/**
 * 测试JdbcUtils类
 * 
 *
 */
public class JdbcUtilsTest {
    /**
     * 通过C3P0连接池获取连接对象
     * @throws SQLException
     */
    @Test
    public void testGetConnection() throws SQLException {
        Connection con = JdbcUtils.getConnection();//获取连接
        System.out.println(con);
        JdbcUtils.releaseConnection(con);//如果参数con不是当前线程的连接对象，那么关闭之
    }
    
    /**
     * 当开始事务后，调用getConnection()会为当前线程创建Connection，而且多次调用getConnection()返回的是同一个对象
     * @throws SQLException 
     */
    @Test
    public void testTansaction() throws SQLException {
        JdbcUtils.beginTransaction();//开启事务
        Connection c1 = JdbcUtils.getConnection();//第一次获取当前线程的事务连接对象
        Connection c2 = JdbcUtils.getConnection();//第二次获取当前线程的事务连接对象
        Assert.assertEquals(true, c1 == c2);//比较两次是否相同
        JdbcUtils.commitTransaction();//提交事务
    }
}

=========================================================================================================================================

3.TxQueryRunner

TxQueryRunner类是common-dbutils下QueryRunner类的子类，用来简化JDBC操作。TxQueryRunner类内部使用了JdbcUtils.getConnection()类来获取连接对象，以及使用JdbcUtils.releaseConnection()关闭连接。

　　l  int[] batch(String sql, Object[][] params)：执行批处理，参数sql是SQL语句模板，params为参数；

　　l  T query(String sql, ResultSetHandler<T> rh)：执行查询，执行查询，参数sql为要执行的查询语句模板，rh是结果集处理，用来把结果集映射成你想要的结果；

　　l  T query(String sql, ResultSetHandler<T> rh, Object… params)：执行查询，参数sql为要执行的查询语句模板，rh是结果集处理，用来把结果集映射成你想要的结果，params是sql语句的参数；

　　l  int update(String sql)：执行增、删、改语句，参数sql是要执行的SQL语句；

　　l  int update(Stringsql, Object param)：执行增、删、改语句，参数sql是要执行的SQL语句，参数param是参数（一个参数）；

　　l  int update(String sql, Object… params)：执行增、删、改语句，参数sql是要执行的SQL语句，参数params是参数（多个参数）；

为了测试TxQueryRunner，我们在mydb1数据库下创建t_person表，然后再创建Person实体类，以及PersonDao类，最后测试PersonDao类中的方法。

　　1.源码

package cn.itcast.jdbc;

import java.sql.Connection;
import java.sql.SQLException;

import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.ResultSetHandler;

public class TxQueryRunner extends QueryRunner {

    @Override
    public int[] batch(String sql, Object[][] params) throws SQLException {
        Connection con = JdbcUtils.getConnection();
        int[] result = super.batch(con, sql, params);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public <T> T query(String sql, ResultSetHandler<T> rsh, Object... params)
            throws SQLException {
        Connection con = JdbcUtils.getConnection();
        T result = super.query(con, sql, rsh, params);
        JdbcUtils.releaseConnection(con);
        return result;
    }
    
    @Override
    public <T> T query(String sql, ResultSetHandler<T> rsh) throws SQLException {
        Connection con = JdbcUtils.getConnection();
        T result = super.query(con, sql, rsh);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public int update(String sql) throws SQLException {
        Connection con = JdbcUtils.getConnection();
        int result = super.update(con, sql);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public int update(String sql, Object param) throws SQLException {
        Connection con = JdbcUtils.getConnection();
        int result = super.update(con, sql, param);
        JdbcUtils.releaseConnection(con);
        return result;
    }

    @Override
    public int update(String sql, Object... params) throws SQLException {
        Connection con = JdbcUtils.getConnection();
        int result = super.update(con, sql, params);
        JdbcUtils.releaseConnection(con);
        return result;
    }
}

　　2.测试代码

Person.java

public class Person {
    private String pid;
    private String name;
    private int age;
    private Date birthday;
…
}

PersonDao.java

/**
 * 测试TxQueryRunner
 *  4  *
 */
public class PersonDao {
    private QueryRunner qr = new TxQueryRunner();
    
    public void add(Person person) throws SQLException {
        String sql = "insert into t_person values(?,?,?,?)";
        Object[] params = {person.getPid(), 
                person.getName(), 
                person.getAge(), 
                new java.sql.Date(person.getBirthday().getTime())};
        qr.update(sql, params);
    }
    
    public void edit(Person person) throws SQLException {
        String sql = "update t_person set name=?,age=?,birthday=? where pid=?";
        Object[] params = { 
                person.getName(), 
                person.getAge(), 
                new java.sql.Date(person.getBirthday().getTime()),
                person.getPid()};
        qr.update(sql, params);
    }
    
    public void delete(String pid) throws SQLException {
        String sql = "delete from t_person where pid=?";
        qr.update(sql, pid);
    }
    
    public Person load(String pid) throws SQLException {
        String sql = "select * from t_person where pid=?";
        return qr.query(sql, new BeanHandler<Person>(Person.class), pid);
    }
    
    public List<Person> findAll() throws SQLException {
        String sql = "select * from t_person";
        return qr.query(sql, new BeanListHandler<Person>(Person.class));
    }
}

PersonDaoTest.java

public class PersonDaoTest {
    @Test
    public void testAdd() throws SQLException {
        Person p1 = new Person(CommonUtils.uuid(), "张三", 18, new Date());
        Person p2 = new Person(CommonUtils.uuid(), "李四", 81, new Date());
        Person p3 = new Person(CommonUtils.uuid(), "王五", 66, new Date());
        
        PersonDao dao = new PersonDao();
        dao.add(p1);
        dao.add(p2);
        dao.add(p3);
    }
    
    @Test
    public void testEdit() throws SQLException {
        PersonDao dao = new PersonDao();
        Person person = dao.load("2F371BE415984DE89781CCCA7B8734CB");
        person.setAge(88);
        dao.edit(person);
    }
    
    @Test
    public void testDelete() throws SQLException {
        PersonDao dao = new PersonDao();
        dao.delete("2F371BE415984DE89781CCCA7B8734CB");
    }
    
    @Test
    public void testFindAll() throws SQLException {
        PersonDao dao = new PersonDao();
        List<Person> list = dao.findAll();
        System.out.println(list);
    }
}

=========================================================================================================================================

4.MailUtils

MailUtils是用来发邮件的小工具，底层使用JavaMail完成，依赖mail.jar和activaion.jar。

　　1.源码

MailUtils.java

package cn.itcast.mail;

import java.io.IOException;
import java.util.List;
import java.util.Properties;

import javax.mail.Authenticator;
import javax.mail.Message.RecipientType;
import javax.mail.MessagingException;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeBodyPart;
import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeMultipart;
import javax.mail.internet.MimeUtility;

/**
 * 
 * @author itcast 本类只有这么一个方法，用来发邮件！
 */
public class MailUtils {
    public static Session createSession(String host, final String username, final String password) {
        Properties prop = new Properties();
        prop.setProperty("mail.host", host);// 指定主机
        prop.setProperty("mail.smtp.auth", "true");// 指定验证为true

        // 创建验证器
        Authenticator auth = new Authenticator() {
            public PasswordAuthentication getPasswordAuthentication() {
                return new PasswordAuthentication(username, password);
            }
        };
        
        // 获取session对象
        return Session.getInstance(prop, auth);
    }
    
    /**
     * 发送指定的邮件
     * 
     * @param mail
     */
    public static void send(Session session, final Mail mail) throws MessagingException,
            IOException {

        MimeMessage msg = new MimeMessage(session);// 创建邮件对象
        msg.setFrom(new InternetAddress(mail.getFrom()));// 设置发件人
        msg.addRecipients(RecipientType.TO, mail.getToAddress());// 设置收件人

        // 设置抄送
        String cc = mail.getCcAddress();
        if (!cc.isEmpty()) {
            msg.addRecipients(RecipientType.CC, cc);
        }

        // 设置暗送
        String bcc = mail.getBccAddress();
        if (!bcc.isEmpty()) {
            msg.addRecipients(RecipientType.BCC, bcc);
        }

        msg.setSubject(mail.getSubject());// 设置主题

        MimeMultipart parts = new MimeMultipart();// 创建部件集对象

        MimeBodyPart part = new MimeBodyPart();// 创建一个部件
        part.setContent(mail.getContent(), "text/html;charset=utf-8");// 设置邮件文本内容
        parts.addBodyPart(part);// 把部件添加到部件集中
        
        ///////////////////////////////////////////

        // 添加附件
        List<AttachBean> attachBeanList = mail.getAttachs();// 获取所有附件
        if (attachBeanList != null) {
            for (AttachBean attach : attachBeanList) {
                MimeBodyPart attachPart = new MimeBodyPart();// 创建一个部件
                attachPart.attachFile(attach.getFile());// 设置附件文件
                attachPart.setFileName(MimeUtility.encodeText(attach
                        .getFileName()));// 设置附件文件名
                String cid = attach.getCid();
                if(cid != null) {
                    attachPart.setContentID(cid);
                }
                parts.addBodyPart(attachPart);
            }
        }

        msg.setContent(parts);// 给邮件设置内容
        Transport.send(msg);// 发邮件
    }
}

Mail.java　　

package cn.itcast.mail;

import java.util.ArrayList;
import java.util.List;

/**
 * 表示邮件类，你需要设置：账户名和密码、收件人、抄送(可选)、暗送(可选)、主题、内容，以及附件(可选)
 * 
 * 在创建了Mail对象之后
 * 可以调用它的setSubject()、setContent()，设置主题和正文
 * 也可以调用setFrom()和　addToAddress()，设置发件人，和添加收件人。
 * 也可以调用addAttch()添加附件
 * 创建AttachBean：new AttachBean(new File("..."), "fileName");
 */
public class Mail {
    private String from;//发件人
    private StringBuilder toAddress = new StringBuilder();//收件人
    private StringBuilder ccAddress = new StringBuilder();//抄送
    private StringBuilder bccAddress = new StringBuilder();//暗送
    
    private String subject;//主题
    private String content;//正文
    
    // 附件列表
    private List<AttachBean> attachList = new ArrayList<AttachBean>();
    
    public Mail() {}
    
    public Mail(String from, String to) {
        this(from, to, null, null);
    }
    
    public Mail(String from, String to, String subject, String content) {
        this.from = from;
        this.toAddress.append(to);
        this.subject = subject;
        this.content = content;
    }
    
    /**
     * 返回发件人
     * @return
     */
    public void setFrom(String from) {
        this.from = from;
    }
    
    /**
     * 返回发件人
     * @return
     */
    public String getFrom() {
        return from;
    }
    
    /**
     * 返回主题
     */
    public String getSubject() {
        return subject;
    }

    /**
     * 设置主题
     */
    public void setSubject(String subject) {
        this.subject = subject;
    }

    /**
     * 获取主题内容
     */
    public String getContent() {
        return content;
    }

    /**
     * 设置主题内容
     * @param content
     */
    public void setContent(String content) {
        this.content = content;
    }

    /**
     * 获取收件人
     * @return
     */
    public String getToAddress() {
        return toAddress.toString();
    }

    /**
     * 获取抄送
     * @return
     */
    public String getCcAddress() {
        return ccAddress.toString();
    }

    /**
     * 获取暗送
     * @return
     */
    public String getBccAddress() {
        return bccAddress.toString();
    }

    /**
     * 添加收件人,可以是多个收件人
     * @param to
     */
    public void addToAddress(String to) {
        if(this.toAddress.length() > 0) {
            this.toAddress.append(",");
        }
        this.toAddress.append(to);
    }

    /**
     * 添加抄送人，可以是多个抄送人
     * @param cc
     */
    public void addCcAddress(String cc) {
        if(this.ccAddress.length() > 0) {
            this.ccAddress.append(",");
        }
        this.ccAddress.append(cc);
    }

    /**
     * 添加暗送人，可以是多个暗送人
     * @param bcc
     */
    public void addBccAddress(String bcc) {
        if(this.bccAddress.length() > 0) {
            this.bccAddress.append(",");
        }
        this.bccAddress.append(bcc);
    }
    
    /**
     * 添加附件，可以添加多个附件
     * @param attachBean
     */
    public void addAttach(AttachBean attachBean) {
        this.attachList.add(attachBean);
    }
    
    /**
     * 获取所有附件
     * @return
     */
    public List<AttachBean> getAttachs() {
        return this.attachList;
    }
}

2.测试代码

    /**
     * 测试发送普通邮件
     * @throws IOException 
     * @throws MessagingException 
     */
    @Test
    public void fun() throws MessagingException, IOException {
        Session session = MailUtils.createSession("smtp.163.com", "itcast_cxf", "itcastitcast"); 
        Mail mail = new Mail("itcast_cxf@163.com", "itcast_cxf@126.com", "测试MailUtils", "这是正文！"); 
        MailUtils.send(session, mail); 
    }

=========================================================================================================================================

5.BaseServlet

　　

　　BaseServlet是用来作为其它Servlet父类的，它有如下两个优点：

　　一个Servlet多个处理方法

　　　　BaseServlet的作用是用来简化Servlet。通过我们需要为每个功能编写一个Servlet，例如用户注册写一个RegistServlet，用户登录写一个LoginServlet。如果使用BaseServlet，那么我们可以只写一个UserServlet，然后让UserServlet去继承BaseServlet，然后在UserServlet给出两个请求处理方法，一个方法叫regist()，一个叫login()。

　　　　BaseServlet来简化了Servlet中请求转发和重定向的代码。

　　简化了请求转发和重定向的代码

　　　　BaseServlet中的请求处理方法有一个String类型的返回值，返回值表示转发或重定向的目标页面。例如：

　　　　l  f:/index.jsp：其中f:表示转发，即forward的意思，/index.jsp表示转发到/index.jsp页面；

　　　　l  r:/index.jsp：其中r:表示重定向，即redirect的意思，/index.jsp表示重定向到/index.jsp页面。

　　　　l  null：表示不转发也不重定向；

　　　　因为BaseServlet中可以有多个请求处理方法，所以在访问BaseServlet时一定要给出名为method的参数来指定要请求的方法名称。