Flink实战（123）：connector（二十）clickhouse写入(三)

package com.caimou.utils;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;

/**
 * Created by Administrator on 2020/2/19.
 */
public class ClickHouseUtils {

    public static void insertData(String tableName,Map<String,String> data,Set<String> intFieldSet){
        /**
         * insert into youfantest (id,name,create_date)values(1,'xiaobai','2018-09-07');
         */
        String resultsql = "insert into ";
        resultsql += tableName +" (";
        String valuesql = "(";
        Set<Map.Entry<String,String>> sets =  data.entrySet();
        for(Map.Entry<String,String> map:sets){
            String fieldName = map.getKey();
            String valuestring = map.getValue();
            resultsql += fiel

最后

以上就是欣慰世界为你收集整理的Flink实战（123）：connector（二十）clickhouse写入(三)的全部内容，希望文章能够帮你解决Flink实战（123）：connector（二十）clickhouse写入(三)所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。