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

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配置

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

时间: 2024-10-08 15:05:10

web每5秒向数据库中插入一条记录-学习笔记的相关文章

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

import java.sql.SQLException; import java.util.Timer; import java.util.TimerTask; import java.util.UUID; import cn.itcast.web.dao.SystemDao; //课程练习1 public class Demo3 { public static void main(String[] args) { Timer timer = new Timer(); timer.schedu

使用JDBC向数据库中插入一条数据

原谅我是初学者,这个方法写的很烂,以后不会改进,谢谢 /** * 通过JDBC向数据库中插入一条数据 1.Statement 用于执行SQL语句的对象 1.1 通过Connection 的 * createStatement() 方法来获取 1.2 通过executeUpdate(sql) 的方法来执行SQL 1.3 * 传入的SQL可以是INSERT/UPDATE/DELETE,但不能是SELECT * * 2.Connection和Statement使用后一定要记得关闭 需要在finally

向数据库中插入10000条数据

今天,在进行项目测试的时候,想要事先在数据库中插入10000条数据.之前在SQLServer的期末项目中也使用过,但是却也记不清了. DELIMITER $$ --定义结束符为"$$", DROP PROCEDURE IF EXISTS `proc_auto_insertdata`$$ CREATE PROCEDURE `proc_auto_insertdata`() BEGIN DECLARE pid INTEGER DEFAULT 1; WHILE pid <= 10000

通过 JDBC 向指定的数据表中插入一条记录,查询记录

//通过 JDBC 向指定的数据表中插入一条记录 /*  * 1.Statement: 用于执行SQl语句的对象  *  通过Connection 的createStatement()方法来获取  *  通过executeUptate(sql) 可执行sql语句  *  传入的sql 可以是 insert , update, delete 但不能是select  * 2.Connection 和 Statement 需要关闭  *  需要在finally中关闭  * 3.关闭的顺序:先关闭后获取

mySQL中插入多条记录

用一条INSERT向SQL中插入多条记录 2008-12-22 10:07:01|  分类: 记事本_编程技术|举报|字号 订阅 Sql 语法: 插入多行记录 Insert Into TableName1 ( column1 ,column2 ) Select column1,column2 From TableName2 Insert Into TableName ( column1,column2 ) Values ( value1,value2 ) , ( value3,value4 )

ACCESS-delphi向中插入一条记录报错,但ACCESS不会

问题:在DELPHI中向ACCESS中插入一条记录时,提示“插入错误”,但是取出SQL直接放在ACCESS中插入成功?答:原因是插入语句中的字段名是DELPHI的内部标示符.

30-4 向表中插入多条记录

----------------------向表中插入多条记录-------------------- --将TblStudent表的结构和表中的数据备份到TblStudent20140506Backup表中. --TblStudent20140506Backup表是在执行 select into 语句时创建的. --select into 语句不能重复执行,因为每次执行都会创建一个TblStudent20140506Backup表. --TblStudent表结构包括自动编号列都会在TblSt

使用JDBC获取数据库中的一条记录并封装为Bean

比如我数据库中存入的是一条一条的用户信息,现在想取出一个人的个人信息,并封装为Bean对象,可以使用queryForObject来获取数据并通过new BeanPropertyRowMapper(Bean.class)将数据转化为javaBean对象. 用法: queryForObject:查询并返回对象 new BeanPropertyRowMapper(Bean.class):是queryForObject的一个参数,将返回的对象封装为什么对象 public User findByid(in

使用JDBC向数据库中插入一条数据(第一次修改版)

增加了一个Tools类,放了一些常用的工具 package com.JDBC.java; import java.io.IOException; import java.io.InputStream; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; /**