This commit is contained in:
温少
2012-05-21 16:01:08 +08:00
parent 2515413e93
commit 0658c1d0a1
19 changed files with 23 additions and 23 deletions
@@ -8,11 +8,11 @@ import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import com.alibaba.druid.common.jdbc.ResultSetBase;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase.ColumnMetaData;
import com.alibaba.druid.hbase.jdbc.HPreparedStatementImpl;
import com.alibaba.druid.hbase.jdbc.HResultSet;
import com.alibaba.druid.hbase.jdbc.HResultSetMetaData;
import com.alibaba.druid.util.jdbc.ResultSetBase;
import com.alibaba.druid.util.jdbc.ResultSetMetaDataBase.ColumnMetaData;
public class ShowTablesPlan implements ExecutePlan {
@@ -21,8 +21,8 @@ import java.util.Properties;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.client.HTableInterface;
import com.alibaba.druid.common.jdbc.ConnectionBase;
import com.alibaba.druid.hbase.HEngine;
import com.alibaba.druid.util.jdbc.ConnectionBase;
public class HBaseConnection extends ConnectionBase implements Connection {
@@ -5,8 +5,6 @@ import java.sql.SQLException;
import java.sql.Types;
import java.util.List;
import com.alibaba.druid.common.jdbc.PreparedStatementBase;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase.ColumnMetaData;
import com.alibaba.druid.hbase.exec.ExecutePlan;
import com.alibaba.druid.hbase.exec.InsertExecutePlan;
import com.alibaba.druid.hbase.exec.ShowTablesPlan;
@@ -25,6 +23,8 @@ import com.alibaba.druid.sql.ast.statement.SQLSelectQueryBlock;
import com.alibaba.druid.sql.ast.statement.SQLSelectStatement;
import com.alibaba.druid.sql.visitor.SQLEvalVisitor;
import com.alibaba.druid.sql.visitor.SQLEvalVisitorUtils;
import com.alibaba.druid.util.jdbc.PreparedStatementBase;
import com.alibaba.druid.util.jdbc.ResultSetMetaDataBase.ColumnMetaData;
public class HPreparedStatementImpl extends PreparedStatementBase implements HPreparedStatement {
@@ -1,6 +1,6 @@
package com.alibaba.druid.hbase.jdbc;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase;
import com.alibaba.druid.util.jdbc.ResultSetMetaDataBase;
public class HResultSetMetaData extends ResultSetMetaDataBase {
@@ -11,10 +11,10 @@ import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.util.Bytes;
import com.alibaba.druid.common.jdbc.ResultSetBase;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase.ColumnMetaData;
import com.alibaba.druid.hbase.mapping.HMapping;
import com.alibaba.druid.util.JdbcUtils;
import com.alibaba.druid.util.jdbc.ResultSetBase;
import com.alibaba.druid.util.jdbc.ResultSetMetaDataBase.ColumnMetaData;
public class HScannerResultSet extends ResultSetBase implements HResultSet {
@@ -3,7 +3,7 @@ package com.alibaba.druid.hbase.jdbc;
import java.sql.SQLException;
import java.sql.Statement;
import com.alibaba.druid.common.jdbc.StatementBase;
import com.alibaba.druid.util.jdbc.StatementBase;
public class HStatementImpl extends StatementBase implements Statement, HStatement {
@@ -34,7 +34,7 @@ import java.util.Map;
import java.util.Properties;
import java.util.concurrent.Executor;
import com.alibaba.druid.common.jdbc.ConnectionBase;
import com.alibaba.druid.util.jdbc.ConnectionBase;
public class MockConnection extends ConnectionBase implements Connection {
@@ -19,7 +19,7 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.alibaba.druid.common.jdbc.PreparedStatementBase;
import com.alibaba.druid.util.jdbc.PreparedStatementBase;
public class MockPreparedStatement extends PreparedStatementBase implements PreparedStatement {
@@ -22,7 +22,7 @@ import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import com.alibaba.druid.common.jdbc.ResultSetBase;
import com.alibaba.druid.util.jdbc.ResultSetBase;
public class MockResultSet extends ResultSetBase implements ResultSet {
@@ -17,7 +17,7 @@ package com.alibaba.druid.mock;
import java.sql.ResultSetMetaData;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase;
import com.alibaba.druid.util.jdbc.ResultSetMetaDataBase;
public class MockResultSetMetaData extends ResultSetMetaDataBase implements ResultSetMetaData {
@@ -20,7 +20,7 @@ import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import com.alibaba.druid.common.jdbc.StatementBase;
import com.alibaba.druid.util.jdbc.StatementBase;
public class MockStatement extends StatementBase implements Statement {
@@ -6,7 +6,6 @@ import java.sql.Timestamp;
import java.sql.Types;
import java.util.List;
import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase.ColumnMetaData;
import com.alibaba.druid.mock.MockResultSet;
import com.alibaba.druid.mock.MockResultSetMetaData;
import com.alibaba.druid.mock.MockStatement;
@@ -31,6 +30,7 @@ import com.alibaba.druid.sql.dialect.mysql.ast.expr.MySqlBooleanExpr;
import com.alibaba.druid.sql.dialect.mysql.ast.statement.CobarShowStatus;
import com.alibaba.druid.sql.dialect.mysql.parser.MySqlStatementParser;
import com.alibaba.druid.sql.parser.SQLStatementParser;
import com.alibaba.druid.util.jdbc.ResultSetMetaDataBase.ColumnMetaData;
public class MySqlMockExecuteHandlerImpl implements MockExecuteHandler {
@@ -1,4 +1,4 @@
package com.alibaba.druid.common.jdbc;
package com.alibaba.druid.util.jdbc;
import java.sql.Connection;
import java.sql.SQLException;
@@ -1,4 +1,4 @@
package com.alibaba.druid.common.jdbc;
package com.alibaba.druid.util.jdbc;
import java.sql.SQLException;
import java.sql.Statement;
@@ -1,4 +1,4 @@
package com.alibaba.druid.common.jdbc;
package com.alibaba.druid.util.jdbc;
import java.io.InputStream;
import java.io.Reader;
@@ -1,4 +1,4 @@
package com.alibaba.druid.common.jdbc;
package com.alibaba.druid.util.jdbc;
import java.io.InputStream;
import java.io.Reader;
@@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.alibaba.druid.common.jdbc;
package com.alibaba.druid.util.jdbc;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
@@ -1,4 +1,4 @@
package com.alibaba.druid.common.jdbc;
package com.alibaba.druid.util.jdbc;
import java.sql.Connection;
import java.sql.ResultSet;