Flink JDBC连接多个租户

Question

我有以下两个类。小学类是 Aloscalcalulation ，它具有一个包含某些值的变量 finalOutput 。DataSet<Tuple4<String, String, Double, String>> finalOutput。该值被尝试插入PostgreSQL。可变连接值是具有JSON，它具有各种参数，例如用户名，密码，驱动器，该参数可从称为OUTermap的hashmap接收到。从WriteAlos中，我可以发送试图在Aloscalcoulation中插入的行对象。但是我无法发送可变连接值来设置驱动程序，密码，URL和用户名。请建议我如何做。相应地计算诸如org_metric_result，org_metric_orgid之类的值。

我现在以一种解决问题的新方式编辑了代码。但是现在，新问题是在Writealos方法中，如果匹配未发生，我会返回一个空的对象。到目前为止，当数据库插入时，我会得到一个例外，说正在形成零值，无法插入。请任何人解决此错误？

    public class Writealos implements MapFunction<Tuple4<String, String, Double, String>, Row> 
    {
        @Autowired
        private Tenantresource outermap;
        public Row map(Tuple4<String, String, Double, String> arg0)throws Exception
        {
            if(arg0.f0.equals(currentKey))
            {
               Row obj = new Row(7);
               String string = RandomStringUtils.randomAlphanumeric(32);
               obj.setField(0, string);
               obj.setField(1, alos);
               obj.setField(2, org_metric_result.toString());
               obj.setField(3, Start_Date.toString());
               obj.setField(4, End_Date.toString());
               obj.setField(5, Execution_Date.toString());
               obj.setField(6, org_metric_orgid);
         }
            return obj; 
        }
    }
    public class Aloscalculation
    {
        @Autowired
    private static Tenantresource outermap;
        public static void calculateAlos(Fhirresource fhir_resource ) throws Exception 
        {
            String query = "insert into reports (org_metric_id,org_metric_topic, org_metric_result, org_metric_from, org_metric_to, org_metric_executed_on, org_metric_orgid) values (?,?,cast(? as json),cast(? as timestamp),cast(? as timestamp),cast(? as timestamp),?)";
         for(String currentKey : outermap.tenantresourcereturn().keySet()) 
         { 
             JSONObject connection =new JSONObject( outermap.tenantresourcereturn().get(currentKey));
             System.out.println(currentKey);
             String url=connection.getString("jdbc_url")+":"+connection.getString("port")+"/"+connection.getString("db_name");
             System.out.println(url);
            finaloutput.map(new Writealos(fhir_resource,currentKey))
                .output(JDBCOutputFormat.buildJDBCOutputFormat()
                .setDrivername()
                .setDBUrl()
                .setUsername()
                .setPassword()
                .setQuery(query)
                .finish());
        }
    }

Answer 1

您如何公开public Row map(Tuple4<String, String, Double, String> arg0)，是通过服务。Spring提供了注释 @ ResponseBody。您需要有一个匹配的Pojo，而春天将负责转换。其次，您为什么不打算使用任何ORM工具（Hibernate，Ibatis等），它可以减轻您的CRUD操作。

spring @Responsebody在此RESTFUL应用程序示例中如何工作？