Alawn/Druid
1
0
Fork 0
mirror of https://github.com/alibaba/druid.git synced 2023-03-04 19:17:16 +00:00
Code Issues Releases Wiki Activity

refactor

Browse Source
This commit is contained in:
温少
2012-05-21 14:55:57 +08:00
parent 4aa084918f
commit 5d3e0093a2
3 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/alibaba/druid/hbase/exec/SingleTableQueryExecutePlan.java
+3 -3
View File
@@ -16,7 +16,7 @@ import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.apache.hadoop.hbase.util.Bytes;
import com.alibaba.druid.hbase.jdbc.HBaseConnection;
import com.alibaba.druid.hbase.jdbc.HBaseResultSet;
import com.alibaba.druid.hbase.jdbc.HScannerResultSet;
import com.alibaba.druid.hbase.jdbc.HPreparedStatementImpl;
import com.alibaba.druid.hbase.jdbc.HResultSetMetaData;
import com.alibaba.druid.hbase.mapping.HMappingTable;
@@ -70,7 +70,7 @@ public class SingleTableQueryExecutePlan extends SingleTableExecutePlan {
}
@Override
public HBaseResultSet executeQuery(HPreparedStatementImpl statement) throws SQLException {
public HScannerResultSet executeQuery(HPreparedStatementImpl statement) throws SQLException {
try {
HBaseConnection connection = statement.getConnection();
String dbType = connection.getConnectProperties().getProperty("dbType");
@@ -122,7 +122,7 @@ public class SingleTableQueryExecutePlan extends SingleTableExecutePlan {
HTableInterface htable = connection.getHTable(getTableName());
ResultScanner scanner = htable.getScanner(scan);
HBaseResultSet resultSet = new HBaseResultSet(statement, htable, scanner);
HScannerResultSet resultSet = new HScannerResultSet(statement, htable, scanner);
resultSet.setMetaData(resultMetaData);
resultSet.setMapping(mapping);
src/main/java/com/alibaba/druid/hbase/jdbc/HBaseResultSet.java → src/main/java/com/alibaba/druid/hbase/jdbc/HScannerResultSet.java
+2 -2
View File
@@ -16,7 +16,7 @@ import com.alibaba.druid.common.jdbc.ResultSetMetaDataBase.ColumnMetaData;
import com.alibaba.druid.hbase.mapping.HMappingTable;
import com.alibaba.druid.util.JdbcUtils;
public class HBaseResultSet extends ResultSetBase implements HResultSet {
public class HScannerResultSet extends ResultSetBase implements HResultSet {
private HStatement statement;
private ResultScanner scanner;
@@ -26,7 +26,7 @@ public class HBaseResultSet extends ResultSetBase implements HResultSet {
private HMappingTable mapping;
public HBaseResultSet(HStatement statement, HTableInterface htable, ResultScanner scanner){
public HScannerResultSet(HStatement statement, HTableInterface htable, ResultScanner scanner){
super(statement);
this.statement = statement;
this.htable = htable;
src/main/java/com/alibaba/druid/hbase/mapping/HMapping.java
+6
View File
@@ -0,0 +1,6 @@
package com.alibaba.druid.hbase.mapping;
public interface HMapping {
}