Springboot+clickhouse 集成demo

package com.nsac.clickhouse.runner; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.CommandLineRunner; import org.springframework.stereotype.Component; import com.alibaba.druid.support.logging.Log; import com.nsac.clickhouse.dao.TestSQLDao; //@Component public class InsertCommandLineRunner implements CommandLineRunner { Logger log = Logger.getLogger(InsertCommandLineRunner.class); @Autowired TestSQLDao testSQLDao; @Override public void run(String... args) throws Exception { SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd"); final String createTime = sdf.format(new Date()); final String createDate = sdf1.format(new Date()); int mac = 000000000000; List<Map<String, Object>> list = new ArrayList<Map<String, Object>>(); int num = 99; int deviceBusinessType = 0; Long startTime = System.currentTimeMillis(); for (int i = 0; i <= 20000000; i++) { mac++; Map<String, Object> map1 = new HashMap<String, Object>(); map1.put("id", num + i); map1.put("mac", num + "-" + mac); map1.put("deviceBusinessType", deviceBusinessType); map1.put("createTime", createTime); map1.put("createDate", createDate); list.add(map1); if (deviceBusinessType == 4) deviceBusinessType = 0; else deviceBusinessType++; if (i != 0 && i % 1000 == 0) { testSQLDao.insertSQL(list); list.clear(); } } if (list.size() != 0) { testSQLDao.insertSQL(list); } System.out.println("单线程执行耗时：" + (System.currentTimeMillis() - startTime) + " ms"); for (int a = 0; a <= 10; a++) { final int aa = a; new Thread(new Runnable() { @Override public void run() { int mac = 000000000000; List<Map<String, Object>> list = new ArrayList<Map<String, Object>>(); int num = aa; int deviceBusinessType = 0; Long startTime = System.currentTimeMillis(); for (int i = 0; i <= 20000000; i++) { mac++; Map<String, Object> map1 = new HashMap<String, Object>(); map1.put("id", num + i); map1.put("mac", num + "-" + mac); map1.put("deviceBusinessType", deviceBusinessType); map1.put("createTime", createTime); map1.put("createDate", createDate); list.add(map1); if (deviceBusinessType == 4) deviceBusinessType = 0; else deviceBusinessType++; if (i != 0 && i % 1000 == 0) { testSQLDao.insertSQL(list); list.clear(); } } if (list.size() != 0) { testSQLDao.insertSQL(list); } System.out.println(num + "执行耗时：" + (System.currentTimeMillis() - startTime) + " ms"); } }).start(); } } }