feat: can connect db with cmd line

Author: fengjiachun

ingester-example/src/main/java/io/greptime/bench/DBConnector.java

@@ -17,8 +17,10 @@
 package io.greptime.bench;
 
 import io.greptime.GreptimeDB;
+import io.greptime.common.util.SystemPropertyUtil;
 import io.greptime.options.GreptimeOptions;
 import io.greptime.quickstart.query.QueryJDBCQuickStart;
+import io.greptime.rpc.RpcOptions;
 import java.io.IOException;
 import java.util.Properties;
 import org.slf4j.Logger;
@@ -38,11 +40,23 @@ public static GreptimeDB connect() {
         } catch (IOException e) {
             throw new RuntimeException(e);
         }
-        String database = (String) prop.get("db.database");
-        String endpointsStr = prop.getProperty("db.endpoints");
+
+        String database = SystemPropertyUtil.get("db.database");
+        if (database == null) {
+            database = (String) prop.get("db.database");
+        }
+
+        String endpointsStr = SystemPropertyUtil.get("db.endpoints");
+        if (endpointsStr == null) {
+            endpointsStr = prop.getProperty("db.endpoints");
+        }
+
         String[] endpoints = endpointsStr.split(",");
+        RpcOptions rpcOptions = RpcOptions.newDefault();
+        rpcOptions.setDefaultRpcTimeout(60 * 1000);
         GreptimeOptions opts = GreptimeOptions.newBuilder(endpoints, database)
                 .writeMaxRetries(0)
+                .rpcOptions(rpcOptions)
                 .defaultStreamMaxWritePointsPerSecond(Integer.MAX_VALUE)
                 .maxInFlightWritePoints(Integer.MAX_VALUE)
                 .useZeroCopyWriteInBulkWrite(true)