huawei
/
openLooKeng-hetu-core
0
0
Fork 4
Code Issues Pull Requests 2 Projects Releases Wiki Activity

3runoob队代码标注 #2

Open
YZK1096 wants to merge 3 commits from YZK1096/openLooKeng-hetu-core:master into master
pull from: YZK1096/openLooKeng-hetu-core:master
merge into: huawei:master
Conversation 0 Commits 3 Files Changed 10 +32 -4
10 changed files with 32 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hetu-carbondata/src/main/java/io/hetu/core/plugin/carbondata/CarbondataMetadata.java
View File

@ -1621,6 +1621,7 @@ public class CarbondataMetadata
}
@Override
//This function is used to add a new column
public void addColumn(ConnectorSession session, ConnectorTableHandle tableHandle, ColumnMetadata column)
{
currentState = State.ADD_COLUMN;
@ -1630,6 +1631,7 @@ public class CarbondataMetadata
}
@Override
//This function is used to rename a column
public void renameColumn(ConnectorSession session, ConnectorTableHandle tableHandle, ColumnHandle source, String target)
{
currentState = State.RENAME_COLUMN;
@ -1646,7 +1648,7 @@ public class CarbondataMetadata
super.dropColumn(session, tableHandle, column);
}
//This function is used to update schema info
private void updateSchemaInfo(ConnectorSession session, ConnectorTableHandle tableHandle, ColumnMetadata column, ColumnHandle source, String target)
{
HiveTableHandle handle = (HiveTableHandle) tableHandle;
@ -1691,7 +1693,7 @@ public class CarbondataMetadata
.add(schemaEvolutionEntry);
}
}
//This function is used to update Schema Info Add Column
private SchemaEvolutionEntry updateSchemaInfoAddColumn(ColumnMetadata column)
{
HiveColumnHandle columnHandle = new HiveColumnHandle(column.getName(), HiveType.toHiveType(typeTranslator, column.getType()),
@ -1764,7 +1766,7 @@ public class CarbondataMetadata
return schemaEvolutionEntry;
}
//This function is used to update Schema Info and Add Column
private SchemaEvolutionEntry updateSchemaInfoRenameColumn(ColumnHandle source, String target)
{
HiveColumnHandle oldColumnHandle = (HiveColumnHandle) source;

1
hetu-carbondata/src/test/java/io/hetu/core/plugin/carbondata/integrationtest/TestCarbonAllDataType.java
View File

@ -1216,6 +1216,7 @@ public class TestCarbonAllDataType
}
@Test
public void testAlterRenameColumn() throws SQLException
{
hetuServer.execute("CREATE TABLE testdb.renamecolumn(NAME varchar(7), AGE int) with(format='CARBON') ");

3
hetu-clickhouse/src/main/java/io/hetu/core/plugin/clickhouse/ClickHouseClient.java
View File

@ -345,6 +345,7 @@ public class ClickHouseClient
}
@Override
//This function is used to rename column
public void renameColumn(JdbcIdentity identity, JdbcTableHandle handle, JdbcColumnHandle jdbcColumn, String inputNewColumnName)
{
String newColumnName = inputNewColumnName;
@ -427,6 +428,7 @@ public class ClickHouseClient
}
@Override
//This function is used to build SQL
public PreparedStatement buildSql(ConnectorSession session, Connection connection, JdbcSplit split, JdbcTableHandle table, List<JdbcColumnHandle> columns)
throws SQLException
{
@ -444,6 +446,7 @@ public class ClickHouseClient
split.getAdditionalPredicate(),
tryApplyLimit(table.getLimit()));
}
// openLooKeng: If the sub-query is not pushed down, use it as the table
return new ClickHouseQueryBuilder(identifierQuote).buildSql(
this,
session,

10
hetu-datacenter/src/main/java/io/hetu/core/plugin/datacenter/DataCenterTableHandle.java
View File

@ -132,6 +132,11 @@ public final class DataCenterTableHandle
}
@JsonProperty
/**
* Get push down SQL
*
* @return the SQL
*/
public String getPushDownSql()
{
return pushDownSql;
@ -144,6 +149,11 @@ public final class DataCenterTableHandle
}
@Override
/**
* Judge whether the objects are equal
*
* @return the boolean
*/
public boolean equals(Object obj)
{
if (this == obj) {

2
hetu-datacenter/src/test/java/io/hetu/core/plugin/datacenter/TestDCDistributedQueries.java
View File

@ -152,6 +152,7 @@ public class TestDCDistributedQueries
}
@Override
//This function tests the renaming column
public void testRenameColumn()
{
// Batch insert through DC connector not supported
@ -161,6 +162,7 @@ public class TestDCDistributedQueries
}
@Override
//This function tests the renaming table function
public void testRenameTable()
{
// Batch insert through DC connector not supported

2
hetu-hana/src/main/java/io/hetu/core/plugin/hana/HanaClient.java
View File

@ -195,6 +195,7 @@ public class HanaClient
}
@Override
//This function is used to rename column
public void renameColumn(JdbcIdentity identity, JdbcTableHandle handle, JdbcColumnHandle jdbcColumn, String newColumnName)
{
try (Connection connection = connectionFactory.openConnection(identity)) {
@ -213,6 +214,7 @@ public class HanaClient
}
@Override
//This function is used to rename designated table
protected void renameTable(JdbcIdentity identity, String catalogName, String schemaName, String tableName, SchemaTableName newTable)
{
try (Connection connection = connectionFactory.openConnection(identity)) {

3
hetu-hana/src/test/java/io/hetu/core/plugin/hana/TestHanaClient.java
View File

@ -164,6 +164,7 @@ public class TestHanaClient
* testRenameColumn
*/
@Test
//This function is used to rename designated column
public void testRenameColumn()
{
String schemaName = getNameByUpperCaseIdentifiers(database.getSchema());
@ -293,7 +294,7 @@ public class TestHanaClient
}
return actualTables;
}
private List<String> getActualColumns(String schemaName, String tableName)
{
try (ResultSet resultSet = connection.getMetaData().getColumns(null, schemaName, tableName, null)) {

5
presto-base-jdbc/src/main/java/io/prestosql/plugin/jdbc/JdbcMetadata.java
View File

@ -311,6 +311,7 @@ public class JdbcMetadata
}
@Override
//This function is used to create schema
public void createSchema(ConnectorSession session, String schemaName, Map<String, Object> properties)
{
jdbcClient.createSchema(session, schemaName);
@ -335,24 +336,28 @@ public class JdbcMetadata
}
@Override
//This function is used to apply a delete
public Optional<ConnectorTableHandle> applyDelete(ConnectorSession session, ConnectorTableHandle handle)
{
return jdbcClient.applyDelete(session, handle);
}
@Override
//This function is used to execute delete
public OptionalLong executeDelete(ConnectorSession session, ConnectorTableHandle handle)
{
return jdbcClient.executeDelete(session, handle);
}
@Override
//This function is used to execute update
public OptionalLong executeUpdate(ConnectorSession session, ConnectorTableHandle handle)
{
return jdbcClient.executeUpdate(session, handle);
}
@Override
//This function is used to begin delete
public ConnectorTableHandle beginDelete(ConnectorSession session, ConnectorTableHandle tableHandle)
{
return jdbcClient.beginDelete(session, tableHandle);

1
presto-base-jdbc/src/main/java/io/prestosql/plugin/jdbc/TransactionScopeCachingJdbcClient.java
View File

@ -83,6 +83,7 @@ public class TransactionScopeCachingJdbcClient
}
@Override
//This function is used to create schema
public void createSchema(ConnectorSession session, String schemaName)
{
getDelegate().createSchema(session, schemaName);

1
presto-hive/src/main/java/io/prestosql/plugin/hive/metastore/thrift/BridgingHiveMetastore.java
View File

@ -232,6 +232,7 @@ public class BridgingHiveMetastore
}
@Override
//This function is used to rename a designated column
public void renameColumn(HiveIdentity identity, String databaseName, String tableName, String oldColumnName, String newColumnName)
{
Optional<org.apache.hadoop.hive.metastore.api.Table> source = delegate.getTable(identity, databaseName, tableName);