add: role

Author: kenkoooo

src/main/java/org/embulk/output/SnowflakeOutputPlugin.java

@@ -54,6 +54,10 @@ public interface SnowflakePluginTask extends PluginTask {
     @ConfigDefault("\"public\"")
     public String getSchema();
 
+    @Config("role")
+    @ConfigDefault("\"\"")
+    public String getRole();
+
     @Config("delete_stage")
     @ConfigDefault("false")
     public boolean getDeleteStage();
@@ -113,6 +117,9 @@ protected JdbcOutputConnector getConnector(PluginTask task, boolean retryableMet
     props.setProperty("warehouse", t.getWarehouse());
     props.setProperty("db", t.getDatabase());
     props.setProperty("schema", t.getSchema());
+    if(!t.getRole().isEmpty()) {
+      props.setProperty("role", t.getRole());
+    }
 
     // When CLIENT_METADATA_REQUEST_USE_CONNECTION_CTX is false (default),
     // getMetaData().getColumns() returns columns of the tables which table name is

src/test/java/org/embulk/output/snowflake/TestSnowflakeOutputPlugin.java

@@ -208,6 +208,7 @@ public void testConfigDefault() throws Exception {
     assertEquals("", task.getUser());
     assertEquals("", task.getPassword());
     assertEquals("public", task.getSchema());
+    assertEquals("", task.getRole());
     assertEquals(false, task.getDeleteStage());
   }