Skip to content

Commit

Permalink
rename class to Lazy
Browse files Browse the repository at this point in the history
  • Loading branch information
LuckyPickleZZ committed Jul 18, 2024
1 parent 33df712 commit 2c24cc6
Show file tree
Hide file tree
Showing 6 changed files with 14 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,13 +23,13 @@
* @author: liuyizhuo.lyz
* @date: 2024/7/11
*/
public class LazyInitObject<T> {
public class Lazy<T> {
private static final Object NO_INIT = new Object();

private volatile T target;
private final Supplier<T> supplier;

public LazyInitObject(@NonNull Supplier<T> supplier) {
public Lazy(@NonNull Supplier<T> supplier) {
target = (T) NO_INIT;
this.supplier = supplier;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,13 +22,13 @@
* @author: liuyizhuo.lyz
* @date: 2024/7/11
*/
public class LazyInitObjectTest {
public class LazyTest {

@Test
public void test_LazyInitialize_Get_Success() {
DummyCounter counter = new DummyCounter();
Assert.assertEquals(0, counter.cnt);
LazyInitObject<DummyCounter> o = new LazyInitObject<>(() -> {
Lazy<DummyCounter> o = new Lazy<>(() -> {
counter.count();
return counter;
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils;

import com.oceanbase.odc.common.util.LazyInitObject;
import com.oceanbase.odc.common.util.Lazy;
import com.oceanbase.odc.core.session.ConnectionSession;
import com.oceanbase.odc.core.session.ConnectionSessionUtil;
import com.oceanbase.odc.service.db.browser.DBSchemaAccessors;
Expand All @@ -53,12 +53,12 @@ abstract class BaseDMLBuilder implements DMLBuilder {
private final String tableName;
private final String schema;
private final List<DataModifyUnit> modifyUnits;
private final LazyInitObject<List<DBTableConstraint>> constraints;
private final Lazy<List<DBTableConstraint>> constraints;
private final List<String> whereColumns;
protected final ConnectionSession connectionSession;

public BaseDMLBuilder(@NonNull List<DataModifyUnit> modifyUnits, List<String> whereColumns,
@NonNull ConnectionSession connectionSession, LazyInitObject<List<DBTableConstraint>> constraints) {
@NonNull ConnectionSession connectionSession, Lazy<List<DBTableConstraint>> constraints) {
Set<String> schemas = modifyUnits.stream()
.map(DataModifyUnit::getSchemaName)
.filter(Objects::nonNull).collect(Collectors.toSet());
Expand All @@ -80,7 +80,7 @@ public BaseDMLBuilder(@NonNull List<DataModifyUnit> modifyUnits, List<String> wh
}
this.connectionSession = connectionSession;
this.constraints =
constraints == null ? new LazyInitObject<>(() -> getConstraints(schema, tableName, connectionSession))
constraints == null ? new Lazy<>(() -> getConstraints(schema, tableName, connectionSession))
: constraints;
this.whereColumns = whereColumns;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@
import java.util.List;
import java.util.Set;

import com.oceanbase.odc.common.util.LazyInitObject;
import com.oceanbase.odc.common.util.Lazy;
import com.oceanbase.odc.core.session.ConnectionSession;
import com.oceanbase.odc.service.dml.model.DataModifyUnit;
import com.oceanbase.tools.dbbrowser.model.DBTableConstraint;
Expand All @@ -40,7 +40,7 @@
public class MySQLDMLBuilder extends BaseDMLBuilder {

public MySQLDMLBuilder(@NonNull List<DataModifyUnit> modifyUnits, List<String> whereColumns,
ConnectionSession connectionSession, LazyInitObject<List<DBTableConstraint>> constraints) {
ConnectionSession connectionSession, Lazy<List<DBTableConstraint>> constraints) {
super(modifyUnits, whereColumns, connectionSession, constraints);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@
import java.util.Objects;
import java.util.Set;

import com.oceanbase.odc.common.util.LazyInitObject;
import com.oceanbase.odc.common.util.Lazy;
import com.oceanbase.odc.core.session.ConnectionSession;
import com.oceanbase.odc.core.shared.constant.OdcConstants;
import com.oceanbase.odc.service.dml.model.DataModifyUnit;
Expand All @@ -42,7 +42,7 @@
public class OracleDMLBuilder extends BaseDMLBuilder {

public OracleDMLBuilder(@NonNull List<DataModifyUnit> modifyUnits, List<String> whereColumns,
ConnectionSession connectionSession, LazyInitObject<List<DBTableConstraint>> constraints) {
ConnectionSession connectionSession, Lazy<List<DBTableConstraint>> constraints) {
super(modifyUnits, whereColumns, connectionSession, constraints);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

import com.oceanbase.odc.common.util.LazyInitObject;
import com.oceanbase.odc.common.util.Lazy;
import com.oceanbase.odc.common.util.StringUtils;
import com.oceanbase.odc.core.authority.util.SkipAuthorize;
import com.oceanbase.odc.core.session.ConnectionSession;
Expand Down Expand Up @@ -74,7 +74,7 @@ public BatchDataModifyResp batchGetModifySql(@NotNull ConnectionSession connecti
BatchDataModifyResp resp = new BatchDataModifyResp();
resp.setTableName(tableName);
resp.setSchemaName(schemaName);
LazyInitObject<List<DBTableConstraint>> constraints = new LazyInitObject<>(
Lazy<List<DBTableConstraint>> constraints = new Lazy<>(
() -> BaseDMLBuilder.getConstraints(schemaName, tableName, connectionSession));
Map<String, DBTableColumn> columnName2Column = getColumnName2Column(connectionSession, schemaName, tableName);
StringBuilder sqlBuilder = new StringBuilder();
Expand Down

0 comments on commit 2c24cc6

Please sign in to comment.