diff --git a/sharding-jdbc-orchestration/src/main/java/io/shardingjdbc/orchestration/jdbc/resultset/MockResultSetMetaData.java b/sharding-jdbc-orchestration/src/main/java/io/shardingjdbc/orchestration/jdbc/resultset/MockResultSetMetaData.java
new file mode 100644
index 0000000000000000000000000000000000000000..eafd1a86e1dbce0e62d0a9e77ca6e4dd2ec2d9e4
--- /dev/null
+++ b/sharding-jdbc-orchestration/src/main/java/io/shardingjdbc/orchestration/jdbc/resultset/MockResultSetMetaData.java
@@ -0,0 +1,144 @@
+/*
+ * Copyright 1999-2015 dangdang.com.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * </p>
+ */
+
+package io.shardingjdbc.orchestration.jdbc.resultset;
+
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+
+/**
+ * Mock resultSet metadata.
+ * 
+ * @author caohao
+ */
+public final class MockResultSetMetaData implements ResultSetMetaData {
+    
+    @Override
+    public int getColumnCount() throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public boolean isAutoIncrement(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public boolean isCaseSensitive(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public boolean isSearchable(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public boolean isCurrency(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public int isNullable(final int column) throws SQLException {
+        return ResultSetMetaData.columnNullable;
+    }
+    
+    @Override
+    public boolean isSigned(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public int getColumnDisplaySize(final int column) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public String getColumnLabel(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public String getColumnName(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public String getSchemaName(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public int getPrecision(final int column) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public int getScale(final int column) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public String getTableName(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public String getCatalogName(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public int getColumnType(final int column) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public String getColumnTypeName(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public boolean isReadOnly(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public boolean isWritable(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public boolean isDefinitelyWritable(final int column) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public String getColumnClassName(final int column) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public <T> T unwrap(final Class<T> iface) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public boolean isWrapperFor(final Class<?> iface) throws SQLException {
+        return false;
+    }
+}
diff --git a/sharding-jdbc-orchestration/src/main/java/io/shardingjdbc/orchestration/jdbc/resultset/MockShardingResultSet.java b/sharding-jdbc-orchestration/src/main/java/io/shardingjdbc/orchestration/jdbc/resultset/MockShardingResultSet.java
new file mode 100644
index 0000000000000000000000000000000000000000..35ccc22e70e149dbfbf09023aed188b401f0e8fd
--- /dev/null
+++ b/sharding-jdbc-orchestration/src/main/java/io/shardingjdbc/orchestration/jdbc/resultset/MockShardingResultSet.java
@@ -0,0 +1,378 @@
+/*
+ * Copyright 1999-2015 dangdang.com.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * </p>
+ */
+
+package io.shardingjdbc.orchestration.jdbc.resultset;
+
+import io.shardingjdbc.core.jdbc.unsupported.AbstractUnsupportedOperationResultSet;
+
+import java.io.InputStream;
+import java.io.Reader;
+import java.math.BigDecimal;
+import java.net.URL;
+import java.sql.Blob;
+import java.sql.Clob;
+import java.sql.Date;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.sql.SQLWarning;
+import java.sql.SQLXML;
+import java.sql.Statement;
+import java.sql.Time;
+import java.sql.Timestamp;
+import java.util.Calendar;
+
+/**
+ * Mock sharding result set.
+ *
+ * @author caohao
+ */
+public final class MockShardingResultSet extends AbstractUnsupportedOperationResultSet {
+    
+    @Override
+    public boolean next() throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public void close() throws SQLException {
+        
+    }
+    
+    @Override
+    public boolean wasNull() throws SQLException {
+        return true;
+    }
+    
+    @Override
+    public String getString(final int columnIndex) throws SQLException {
+        return "";
+    }
+    
+    @Override
+    public String getString(final String columnLabel) throws SQLException {
+        return "";
+    }
+    
+    @Override
+    public boolean getBoolean(final int columnIndex) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public boolean getBoolean(final String columnLabel) throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public byte getByte(final int columnIndex) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public byte getByte(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public short getShort(final int columnIndex) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public short getShort(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public int getInt(final int columnIndex) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public int getInt(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public long getLong(final int columnIndex) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public long getLong(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public float getFloat(final int columnIndex) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public float getFloat(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public double getDouble(final int columnIndex) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public double getDouble(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public byte[] getBytes(final int columnIndex) throws SQLException {
+        return new byte[0];
+    }
+    
+    @Override
+    public byte[] getBytes(final String columnLabel) throws SQLException {
+        return new byte[0];
+    }
+    
+    @Override
+    public Date getDate(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Date getDate(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Date getDate(final int columnIndex, final Calendar cal) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Date getDate(final String columnLabel, final Calendar cal) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Time getTime(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Time getTime(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Time getTime(final int columnIndex, final Calendar cal) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Time getTime(final String columnLabel, final Calendar cal) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Timestamp getTimestamp(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Timestamp getTimestamp(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Timestamp getTimestamp(final int columnIndex, final Calendar cal) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Timestamp getTimestamp(final String columnLabel, final Calendar cal) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public InputStream getAsciiStream(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public InputStream getAsciiStream(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public InputStream getUnicodeStream(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public InputStream getUnicodeStream(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public InputStream getBinaryStream(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public InputStream getBinaryStream(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public SQLWarning getWarnings() throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public void clearWarnings() throws SQLException {
+        
+    }
+    
+    @Override
+    public ResultSetMetaData getMetaData() throws SQLException {
+        return new MockResultSetMetaData();
+    }
+    
+    @Override
+    public Object getObject(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Object getObject(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public int findColumn(final String columnLabel) throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public Reader getCharacterStream(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Reader getCharacterStream(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public BigDecimal getBigDecimal(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public BigDecimal getBigDecimal(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public BigDecimal getBigDecimal(final int columnIndex, final int scale) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public BigDecimal getBigDecimal(final String columnLabel, final int scale) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public void setFetchDirection(final int direction) throws SQLException {
+    }
+    
+    @Override
+    public int getFetchDirection() throws SQLException {
+        return ResultSet.FETCH_FORWARD;
+    }
+    
+    @Override
+    public void setFetchSize(final int rows) throws SQLException {
+    }
+    
+    @Override
+    public int getFetchSize() throws SQLException {
+        return 0;
+    }
+    
+    @Override
+    public int getType() throws SQLException {
+        return ResultSet.TYPE_FORWARD_ONLY;
+    }
+    
+    @Override
+    public int getConcurrency() throws SQLException {
+        return ResultSet.CONCUR_READ_ONLY;
+    }
+    
+    @Override
+    public Statement getStatement() throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Blob getBlob(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Blob getBlob(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Clob getClob(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public Clob getClob(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public URL getURL(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public URL getURL(final String columnLabel) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public boolean isClosed() throws SQLException {
+        return false;
+    }
+    
+    @Override
+    public SQLXML getSQLXML(final int columnIndex) throws SQLException {
+        return null;
+    }
+    
+    @Override
+    public SQLXML getSQLXML(final String columnLabel) throws SQLException {
+        return null;
+    }
+}