update load mount table

HdfsMetaInfoSchema.java

@@ -70,7 +70,7 @@ private HdfsMetaInfoSchema() throws SQLException {
               + "   lastAllocatedStripedBlockId bigint"
               + ");"
               + "CREATE TABLE mount("
-              + "   namenode varchar, path varchar, readOnly smallint,"
+              + "   namenode varchar, path varchar, readOnly int,"
               + "   PRIMARY KEY(namenode, path)"
               + ");"
               + "CREATE VIEW namenodes("

hadoop-hdfs-project/hadoop-hdfs-db/src/main/java/org/apache/hadoop/hdfs/db/DatabaseMountTable.java

@@ -19,7 +19,7 @@ public class DatabaseMountTable {
   public DatabaseMountTable() {}
 
   public static void insertEntries(
-      final String[] namenodes, final String[] paths, final Integer[] readonlys) {
+      final String[] namenodes, final String[] paths, final Long[] readonlys) {
     try {
       DatabaseConnection obj = Database.getInstance().getConnection();
       String env = System.getenv("DATABASE");
@@ -243,6 +243,7 @@ public static Boolean isUnified(String filePath) {
     return res;
   }
 
+  // Run a command-line from user
   public static void dumpMountTable() {
     try {
       DatabaseConnection obj = new DatabaseConnection();
@@ -298,4 +299,41 @@ public static void dumpMountTable() {
       System.err.println(ex.getMessage());
     }
   }
+
+  // Run a command-line from user
+  public static void loadEntries(
+      final String[] namenodes, final String[] paths, final Long[] readonlys) {
+    try {
+      DatabaseConnection obj = new DatabaseConnection();
+      String env = System.getenv("DATABASE");
+      if (env.equals("VOLT")) {
+        try {
+          obj.getVoltClient().callProcedure("InsertMountEntries", namenodes, paths, readonlys);
+        } catch (Exception e) {
+          e.printStackTrace();
+        }
+      } else {
+        String sql =
+            "INSERT INTO mount("
+                + " namenode, path, readOnly"
+                + ") VALUES (?, ?, ?) ON CONFLICT(namenode, path) DO NOTHING;";
+        sql = StringUtils.repeat(sql, namenodes.length);
+
+        Connection conn = obj.getConnection();
+        PreparedStatement pst = conn.prepareStatement(sql);
+        for (int i = 0; i < namenodes.length; ++i) {
+          pst.setString(i * 3 + 1, namenodes[i]);
+          pst.setString(i * 3 + 2, paths[i]);
+          pst.setLong(i * 3 + 3, readonlys[i]);
+        }
+        pst.executeUpdate();
+        pst.close();
+      }
+    } catch (SQLException ex) {
+      System.err.println(ex.getMessage());
+    }
+    if (LOG.isInfoEnabled()) {
+      LOG.info("loadEntries ...");
+    }
+  }
 }

hadoop-hdfs-project/hadoop-hdfs-nnproxy/src/main/java/org/apache/hadoop/hdfs/nnproxy/server/mount/MountsManager.java

@@ -91,17 +91,21 @@ public void load(String mounts) throws Exception {
 
         List<String> namenodes = new ArrayList<String>();
         List<String> paths = new ArrayList<String>();
-        List<Integer> readonlys = new ArrayList<Integer>();
+        List<Long> readonlys = new ArrayList<Long>();
 
         for (int i = 0; i < splitted.length; i = i + 3) {
             namenodes.add(splitted[i]);
-            paths.add((splitted[i + 1]).replaceAll("/$", "")); 
-            readonlys.add(Integer.valueOf(splitted[i + 2]));
+            if (splitted[i + 1].length() > 1) { 
+                paths.add((splitted[i + 1]).replaceAll("/$", ""));
+            } else {
+                paths.add(splitted[i + 1]); 
+            }
+            readonlys.add(Long.valueOf(splitted[i + 2]));
         }
 
-        DatabaseMountTable.insertEntries(
+        DatabaseMountTable.loadEntries(
             namenodes.toArray(new String[namenodes.size()]),
             paths.toArray(new String[paths.size()]),
-            readonlys.toArray(new Integer[readonlys.size()]));        
+            readonlys.toArray(new Long[readonlys.size()]));        
     }
 }

voltdb/InsertMountEntries.java

@@ -5,7 +5,7 @@ public class InsertMountEntries extends VoltProcedure {
   public final SQLStmt sql =
       new SQLStmt("UPSERT INTO mount(namenode, path, readOnly) VALUES (?, ?, ?);");
 
-  public long run(final String[] namenodes, final String[] paths, final Integer[] readonlys)
+  public long run(final String[] namenodes, final String[] paths, final long[] readonlys)
       throws VoltAbortException {
     for (int i = 0; i < namenodes.length; ++i) {
       voltQueueSQL(sql, namenodes[i], paths[i], readonlys[i]);