src/main/java/org/embulk/input/sqlserver/SQLServerInputConnection.java in embulk-input-sqlserver-0.6.3 vs src/main/java/org/embulk/input/sqlserver/SQLServerInputConnection.java in embulk-input-sqlserver-0.6.4

@@ -1,10 +1,9 @@
 package org.embulk.input.sqlserver;
 
 import java.sql.Connection;
 import java.sql.SQLException;
-
 import org.embulk.input.jdbc.JdbcInputConnection;
 
 public class SQLServerInputConnection extends JdbcInputConnection {
 
     public SQLServerInputConnection(Connection connection, String schemaName) throws SQLException
@@ -14,8 +13,19 @@
 
     @Override
     protected void setSearchPath(String schema) throws SQLException
     {
         // NOP
+    }
+
+    @Override
+    protected String buildTableName(String tableName)
+    {
+        StringBuilder sb = new StringBuilder();
+        if (schemaName != null) {
+            sb.append(quoteIdentifierString(schemaName)).append(".");
+        }
+        sb.append(quoteIdentifierString(tableName));
+        return sb.toString();
     }
 
 }