首页 > 数据库技术 > 详细

web每5秒向数据库中插入一条记录-学习笔记

时间:2018-04-20 10:48:47      阅读:167      评论:0      收藏:0      [点我收藏+]
SystemListener

import java.util.Timer;
import java.util.TimerTask;
import java.util.UUID;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import cn.itcast.web.dao.SystemDao;

public class SystemListener implements ServletContextListener {
    private Timer timer = new Timer();
    public void contextInitialized(ServletContextEvent sce) {
        try {
            SystemDao systemDao = new SystemDao();
            systemDao.createTable("systemInit");
            timer.schedule(new SystemTask(),0,5*1000);
        } catch (Exception e) {
        }
    }
    public void contextDestroyed(ServletContextEvent sce) {
        try {
            SystemDao systemDao = new SystemDao();
            systemDao.dropTable("systemInit");
            //中止定时器
            timer.cancel();
        } catch (Exception e) {
        }
    }
}
//任务类
class SystemTask extends TimerTask{
    public void run() {
        try {
            SystemDao systemDao = new SystemDao();
            systemDao.init("systemInit",UUID.randomUUID().toString());
        } catch (Exception e) {
        }
    }
}


*/

import java.sql.SQLException;
import org.apache.commons.dbutils.QueryRunner;
import cn.itcast.web.util.JdbcUtil;

public class SystemDao {
    //删除表
    public void dropTable(String tableName) throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "drop table if exists " + tableName;
        runner.update(sql);
    }

    //创建表
    public void createTable(String tableName) throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "create table if not exists "+tableName+"(id varchar(40) primary key,curr_time timestamp not null)";
        runner.update(sql);
    }

    //初始化数据
    public void init(String tableName,String id) throws SQLException{
        QueryRunner runner = new QueryRunner(JdbcUtil.getDataSource());
        String sql = "insert into "+tableName+"(id) values(?)";
        runner.update(sql,id);
    }
}

web.xml配置

web每5秒向数据库中插入一条记录-学习笔记

原文:http://blog.51cto.com/357712148/2105646

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!