手机端小强原创文章,java小强个人博客站点
当前位置: 首页 >> 理论 >> 使用 JdbcTemplate 动态创建表并添加数据 动态连表查询

使用 JdbcTemplate 动态创建表并添加数据 动态连表查询

30970 理论 | 2014-9-5

前面已经说了一个动态的根据当前时间创建表和插入数据的示例,那么如何进行动态的查询呢?

 

我写了这样一个公共方法,仅供参考!

 

这里需要传递两个时间间隔参数,根据时间间隔判断相差的月数,然后从起始时间开始递增月份,然后动态拼装表的名称,如果存在该表则标记需要查询

所有的SQL通过 union all 来连接,最后增加分页的参数,分页只适合MySQL数据库

当然这个示例也只是适合于按月份来存储的情况

 

代码并不是很复杂,希望大家还是通过代码来理解一下:

package com;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;
/**
 * @说明 进行测试
 * @author cuisuqiang
 * @version 1.0
 * @since
 */
public class DbTest {
 private static ApplicationContext context = null;
 @SuppressWarnings("unchecked")
 public static void main(String[] args) {
  context = new ClassPathXmlApplicationContext("applicationContext.xml");
  String sql = "select * from :TABLE_NAME";
  String key = "nm_cpu_log";
  String beginTime = "2012-1-1 12:12:12";
  String endTime = "2014-12-1 12:12:12";
  String formatkey = "yyyy_MM";
  List list = getListFromEachTable(sql,key,beginTime,endTime,formatkey,1,100);
  if(null != list){
   System.out.println(list.size());
  }else{
   System.out.println("没有数据!");
  }
 }
 /**
  * 动态查询表数据
  * @param sqlTemplate 要执行的单条SQL 其中表名称用 :TABLE_NAME 标识
  * @param tableKey 表前缀,不包含和时间中间的 下划线
  * @param dateBegin 开始时间 yyyy-MM-dd HH:mm:ss
  * @param dateEnd 结束时间 yyyy-MM-dd HH:mm:ss
  * @param dateFormat 时间格式化方式
  * @param pageIndex 分页索引 从 1 开始
  * @param pageCount 每页查询数量 无限制
  * @return 模版查询直接返回
  */
 @SuppressWarnings("unchecked")
 public synchronized static List getListFromEachTable(String sqlTemplate,
   String tableKey, String dateBegin, String dateEnd,
   String dateFormat, int pageIndex, int pageCount) {
  List list = null;
  try {
   // 一共有多少需要执行的SQL
   List<String> sqlList = new ArrayList<String>();
   JdbcTemplate jt = (JdbcTemplate) context.getBean("jdbcTemplate");
   // 转为时间
   Date dbegin = StringToDateTime(dateBegin);
   Date dend = StringToDateTime(dateEnd);
   // 相差的月数
   int monthCount = calculateMonthIn(dend, dbegin);
   for (int i = 0; i <= monthCount; i++) {
    // 下 N 个月的时间
    Date d = getNextMonth(dbegin, i);
    SimpleDateFormat format = new SimpleDateFormat(dateFormat);
    // 动态表名
    String tableName = tableKey + "_" + format.format(d);
    // 如果有某表
    if (getAllTableName(jt, tableName)) {
     System.out.println("存在表:" + tableName);
     // 替换名称获得SQL
     String sql = sqlTemplate.replace(":TABLE_NAME", tableName);
     sqlList.add(sql);
    }
   }
   // 实际要执行的SQL
   StringBuffer sqlGo = new StringBuffer("");
   if (sqlList.size() > 0) {
    for (int i = 0; i < sqlList.size(); i++) {
     if (i == sqlList.size() - 1) {
      sqlGo.append(sqlList.get(i));
     } else {
      sqlGo.append(sqlList.get(i) + " union all ");
     }
    }
   }
   if (sqlList.size() > 0) {
    // 增加分页
    int cindex = (pageIndex - 1) * pageCount;
    sqlGo.append(" limit " + cindex + "," + pageCount);
   }
   if (!"".equals(sqlGo.toString())) {
    System.out.println("执行的SQL:" + sqlGo.toString());
    // 执行查询
    list = jt.queryForList(sqlGo.toString());
   }
  } catch (Exception e) {
   e.printStackTrace();
   list = null;
  }
  return list;
 }
 /**
  * 将传入的字符串按yyyy-MM-dd HH:mm:ss格式转换成对应的日期对象
  * @param str 需要转换的字符串
  */
 public synchronized static Date StringToDateTime(String str) {
  String _pattern = "yyyy-MM-dd HH:mm:ss";
  return StringToDate(str, _pattern);
 }
 /**
  * 将插入的字符串按格式转换成对应的日期对象
  * @param str 字符串
  * @param pattern 格式
  */
 public synchronized static Date StringToDate(String str, String pattern) {
  Date dateTime = null;
  try {
   if (str != null && !str.equals("")) {
    SimpleDateFormat formater = new SimpleDateFormat(pattern);
    dateTime = formater.parse(str);
   }
  } catch (Exception ex) {
   ex.printStackTrace();
  }
  return dateTime;
 }
 /**
  * 两个时间相差的月数
  * @param date1
  * @param date2
  * @return
  */
 public static int calculateMonthIn(Date date1, Date date2) {
  Calendar cal1 = new GregorianCalendar();
  cal1.setTime(date1);
  Calendar cal2 = new GregorianCalendar();
  cal2.setTime(date2);
  int c = (cal1.get(Calendar.YEAR) - cal2.get(Calendar.YEAR)) * 12
    + cal1.get(Calendar.MONTH) - cal2.get(Calendar.MONTH);
  return c;
 }
 /**
  * 获得下几个月的时间对象
  * @param date
  * @param count
  * @return
  */
 public static Date getNextMonth(Date date, int count) {
  Calendar c = Calendar.getInstance();
  c.setTime(date);
  c.add(Calendar.MONTH, count);
  return c.getTime();
 }
 /**
  * 查询数据库是否有某表
  * @param jt
  * @param tableName
  * @return
  * @throws Exception
  */
 @SuppressWarnings("unchecked")
 public static boolean getAllTableName(JdbcTemplate jt, String tableName)
   throws Exception {
  Connection conn = jt.getDataSource().getConnection();
  ResultSet tabs = null;
  try {
   DatabaseMetaData dbMetaData = conn.getMetaData();
   String[] types = { "TABLE" };
   tabs = dbMetaData.getTables(null, null, tableName, types);
   if (tabs.next()) {
    return true;
   }
  } catch (Exception e) {
   e.printStackTrace();
  } finally {
   tabs.close();
   conn.close();
  }
  return false;
 }
}

大家也可以参考我博客其他文章加深认识。

推荐您阅读更多有关于“ mysql sql java 数据库 动态 ”的文章

上一篇:改模版改的怒了 下一篇:使用JDBC查询是否存在某表或视图,按月动态生成表

猜你喜欢

发表评论:

个人资料
blogger

java小强
没有思考,人生的路会越走越难!

搜索
分类
最新微语
  • 不是本人但真实经历,如果你得了绝症抑或大病,能告诉的人两只手能数过来,而能一直陪床真正帮你的人,一只手就够了。也许你会说我亲戚多哥们多同学多云云,但真遇上的时候,你敢说吗?即使你说了会有人像你想的那样吗?不要尝试考验人性,人走茶凉之类的话都听过,但不遇到事我们未曾理解其中的道理。

    2018-11-07 11:05

  • 每个人的一生都是不同的,我们都需要负重前行。每一种生活都是不同的,我们都需要真实面对。所经历的,让我学会一件事,顺其自然。人,总有很多自己想要的,总有很多困难要面对,总有很多人要去爱,我们不断思考人生,却总是迷失自己。如今,我们最缺的不是金钱和时间,而是忘记了自己的初衷。

    2018-09-28 14:42

  • 车也学了,年也过了,生日也过了,村里的会也赶了,这次,是真的,年过去了。不过我没回京,也没有在家找工作,我在等什么吗?反正现在正合了我这个懒人的要求,不过,我歇不住,思考下人生。

    2018-03-20 00:11

  • 8月1日,我已离开奋斗多年的北京。不知道是暂时的离开,还是永久的离别,反正已经离职在家,告别每日上班,每天苦累的煎熬,过一段属于自己的生活。以前是专职工作,现在专职生活。

    2017-08-18 12:47

  • 又弄完一个项目,累成狗,但是感觉又进步不少,除了很多坑已经踩过,做起来也是轻车熟路。同时也认识到,程序不在于你多牛逼,而是在乎你的细节把控度,而细节的关注,是一个优秀程序员必须要注意的。另外,要相信自己,勇敢向前,没人生下来就是成功的,而且,成功的路,比成功本身更重要。

    2017-06-30 09:46

  • 更多»

最新文章
热门文章
随机文章