Merge remote-tracking branch 'origin/2.10' into 2.10

This commit is contained in:
zhouhao 2025-06-24 11:03:08 +08:00
commit bed9337550
1 changed files with 9 additions and 1 deletions

View File

@ -15,6 +15,7 @@
*/
package org.jetlinks.community.timescaledb.thing;
import com.google.common.collect.Sets;
import lombok.extern.slf4j.Slf4j;
import org.hswebframework.ezorm.rdb.codec.DateTimeCodec;
import org.hswebframework.ezorm.rdb.metadata.RDBIndexMetadata;
@ -23,7 +24,6 @@ import org.hswebframework.ezorm.rdb.metadata.RDBTableMetadata;
import org.hswebframework.ezorm.rdb.operator.DatabaseOperator;
import org.hswebframework.ezorm.rdb.operator.ddl.TableBuilder;
import org.jetlinks.core.metadata.PropertyMetadata;
import org.jetlinks.community.Interval;
import org.jetlinks.community.things.data.ThingsDataConstants;
import org.jetlinks.community.things.data.operations.ColumnModeDDLOperationsBase;
import org.jetlinks.community.things.data.operations.DataSettings;
@ -44,6 +44,11 @@ public class TimescaleDBColumnModeDDLOperations extends ColumnModeDDLOperationsB
private final TimescaleDBThingsDataProperties properties;
static Set<String> ignoreColumn = Sets.newHashSet(
ThingsDataConstants.COLUMN_ID,
ThingsDataConstants.COLUMN_MESSAGE_ID
);
public TimescaleDBColumnModeDDLOperations(String thingType,
String templateId,
String thingId,
@ -70,6 +75,9 @@ public class TimescaleDBColumnModeDDLOperations extends ColumnModeDDLOperationsB
List<String> partitions = new ArrayList<>();
partitions.add(ThingsDataConstants.COLUMN_THING_ID);
for (PropertyMetadata property : properties) {
if (ignoreColumn.contains(property.getId())) {
continue;
}
builder
.addColumn(property.getId())
.custom(column -> {