Skip to content

Commit bf07310

Browse files
nakamura-tonakamura-to
authored
Merge pull request #415 from domaframework/settings
Add the Settings class and throw an exception on update/delete without WHERE clause.
2 parents a7b464c + 289f7c4 commit bf07310

33 files changed

+380
-196
lines changed

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/Entityql.java‎

Lines changed: 43 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,11 @@
44
import java.util.Objects;
55
import java.util.function.Consumer;
66
import org.seasar.doma.jdbc.Config;
7-
import org.seasar.doma.jdbc.criteria.context.Options;
7+
import org.seasar.doma.jdbc.criteria.context.DeleteSettings;
8+
import org.seasar.doma.jdbc.criteria.context.InsertSettings;
89
import org.seasar.doma.jdbc.criteria.context.SelectContext;
10+
import org.seasar.doma.jdbc.criteria.context.SelectSettings;
11+
import org.seasar.doma.jdbc.criteria.context.UpdateSettings;
912
import org.seasar.doma.jdbc.criteria.declaration.SelectFromDeclaration;
1013
import org.seasar.doma.jdbc.criteria.def.EntityDef;
1114
import org.seasar.doma.jdbc.criteria.statement.EntityqlBatchDeleteStatement;
@@ -31,11 +34,11 @@ public <ENTITY> EntityqlSelectStatement<ENTITY> from(EntityDef<ENTITY> entityDef
3134
}
3235

3336
public <ENTITY> EntityqlSelectStatement<ENTITY> from(
34-
EntityDef<ENTITY> entityDef, Consumer<Options> optionsConsumer) {
37+
EntityDef<ENTITY> entityDef, Consumer<SelectSettings> settingsConsumer) {
3538
Objects.requireNonNull(entityDef);
36-
Objects.requireNonNull(optionsConsumer);
39+
Objects.requireNonNull(settingsConsumer);
3740
SelectContext context = new SelectContext(entityDef);
38-
optionsConsumer.accept(context.getOptions());
41+
settingsConsumer.accept(context.getSettings());
3942
SelectFromDeclaration declaration = new SelectFromDeclaration(context);
4043
return new EntityqlSelectStatement<>(config, declaration);
4144
}
@@ -47,13 +50,13 @@ public <ENTITY> Statement<ENTITY> update(EntityDef<ENTITY> entityDef, ENTITY ent
4750
}
4851

4952
public <ENTITY> Statement<ENTITY> update(
50-
EntityDef<ENTITY> entityDef, ENTITY entity, Consumer<Options> optionsConsumer) {
53+
EntityDef<ENTITY> entityDef, ENTITY entity, Consumer<UpdateSettings> settingsConsumer) {
5154
Objects.requireNonNull(entityDef);
5255
Objects.requireNonNull(entity);
53-
Objects.requireNonNull(optionsConsumer);
54-
Options options = new Options();
55-
optionsConsumer.accept(options);
56-
return new EntityqlUpdateStatement<>(config, entityDef, entity, options);
56+
Objects.requireNonNull(settingsConsumer);
57+
UpdateSettings settings = new UpdateSettings();
58+
settingsConsumer.accept(settings);
59+
return new EntityqlUpdateStatement<>(config, entityDef, entity, settings);
5760
}
5861

5962
public <ENTITY> Statement<ENTITY> delete(EntityDef<ENTITY> entityDef, ENTITY entity) {
@@ -63,13 +66,13 @@ public <ENTITY> Statement<ENTITY> delete(EntityDef<ENTITY> entityDef, ENTITY ent
6366
}
6467

6568
public <ENTITY> Statement<ENTITY> delete(
66-
EntityDef<ENTITY> entityDef, ENTITY entity, Consumer<Options> optionsConsumer) {
69+
EntityDef<ENTITY> entityDef, ENTITY entity, Consumer<DeleteSettings> settingsConsumer) {
6770
Objects.requireNonNull(entityDef);
6871
Objects.requireNonNull(entity);
69-
Objects.requireNonNull(optionsConsumer);
70-
Options options = new Options();
71-
optionsConsumer.accept(options);
72-
return new EntityqlDeleteStatement<>(config, entityDef, entity, options);
72+
Objects.requireNonNull(settingsConsumer);
73+
DeleteSettings settings = new DeleteSettings();
74+
settingsConsumer.accept(settings);
75+
return new EntityqlDeleteStatement<>(config, entityDef, entity, settings);
7376
}
7477

7578
public <ENTITY> Statement<ENTITY> insert(EntityDef<ENTITY> entityDef, ENTITY entity) {
@@ -79,13 +82,13 @@ public <ENTITY> Statement<ENTITY> insert(EntityDef<ENTITY> entityDef, ENTITY ent
7982
}
8083

8184
public <ENTITY> Statement<ENTITY> insert(
82-
EntityDef<ENTITY> entityDef, ENTITY entity, Consumer<Options> optionsConsumer) {
85+
EntityDef<ENTITY> entityDef, ENTITY entity, Consumer<InsertSettings> settingsConsumer) {
8386
Objects.requireNonNull(entityDef);
8487
Objects.requireNonNull(entity);
85-
Objects.requireNonNull(optionsConsumer);
86-
Options options = new Options();
87-
optionsConsumer.accept(options);
88-
return new EntityqlInsertStatement<>(config, entityDef, entity, options);
88+
Objects.requireNonNull(settingsConsumer);
89+
InsertSettings settings = new InsertSettings();
90+
settingsConsumer.accept(settings);
91+
return new EntityqlInsertStatement<>(config, entityDef, entity, settings);
8992
}
9093

9194
public <ENTITY> Statement<List<ENTITY>> update(
@@ -96,13 +99,15 @@ public <ENTITY> Statement<List<ENTITY>> update(
9699
}
97100

98101
public <ENTITY> Statement<List<ENTITY>> update(
99-
EntityDef<ENTITY> entityDef, List<ENTITY> entities, Consumer<Options> optionsConsumer) {
102+
EntityDef<ENTITY> entityDef,
103+
List<ENTITY> entities,
104+
Consumer<UpdateSettings> settingsConsumer) {
100105
Objects.requireNonNull(entityDef);
101106
Objects.requireNonNull(entities);
102-
Objects.requireNonNull(optionsConsumer);
103-
Options options = new Options();
104-
optionsConsumer.accept(options);
105-
return new EntityqlBatchUpdateStatement<>(config, entityDef, entities, options);
107+
Objects.requireNonNull(settingsConsumer);
108+
UpdateSettings settings = new UpdateSettings();
109+
settingsConsumer.accept(settings);
110+
return new EntityqlBatchUpdateStatement<>(config, entityDef, entities, settings);
106111
}
107112

108113
public <ENTITY> Statement<List<ENTITY>> delete(
@@ -113,13 +118,15 @@ public <ENTITY> Statement<List<ENTITY>> delete(
113118
}
114119

115120
public <ENTITY> Statement<List<ENTITY>> delete(
116-
EntityDef<ENTITY> entityDef, List<ENTITY> entities, Consumer<Options> optionsConsumer) {
121+
EntityDef<ENTITY> entityDef,
122+
List<ENTITY> entities,
123+
Consumer<DeleteSettings> settingsConsumer) {
117124
Objects.requireNonNull(entityDef);
118125
Objects.requireNonNull(entities);
119-
Objects.requireNonNull(optionsConsumer);
120-
Options options = new Options();
121-
optionsConsumer.accept(options);
122-
return new EntityqlBatchDeleteStatement<>(config, entityDef, entities, options);
126+
Objects.requireNonNull(settingsConsumer);
127+
DeleteSettings settings = new DeleteSettings();
128+
settingsConsumer.accept(settings);
129+
return new EntityqlBatchDeleteStatement<>(config, entityDef, entities, settings);
123130
}
124131

125132
public <ENTITY> Statement<List<ENTITY>> insert(
@@ -130,12 +137,14 @@ public <ENTITY> Statement<List<ENTITY>> insert(
130137
}
131138

132139
public <ENTITY> Statement<List<ENTITY>> insert(
133-
EntityDef<ENTITY> entityDef, List<ENTITY> entities, Consumer<Options> optionsConsumer) {
140+
EntityDef<ENTITY> entityDef,
141+
List<ENTITY> entities,
142+
Consumer<InsertSettings> settingsConsumer) {
134143
Objects.requireNonNull(entityDef);
135144
Objects.requireNonNull(entities);
136-
Objects.requireNonNull(optionsConsumer);
137-
Options options = new Options();
138-
optionsConsumer.accept(options);
139-
return new EntityqlBatchInsertStatement<>(config, entityDef, entities, options);
145+
Objects.requireNonNull(settingsConsumer);
146+
InsertSettings settings = new InsertSettings();
147+
settingsConsumer.accept(settings);
148+
return new EntityqlBatchInsertStatement<>(config, entityDef, entities, settings);
140149
}
141150
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/NativeSql.java‎

Lines changed: 16 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,13 @@
77
import org.seasar.doma.jdbc.Config;
88
import org.seasar.doma.jdbc.ObjectProvider;
99
import org.seasar.doma.jdbc.criteria.context.DeleteContext;
10+
import org.seasar.doma.jdbc.criteria.context.DeleteSettings;
1011
import org.seasar.doma.jdbc.criteria.context.InsertContext;
11-
import org.seasar.doma.jdbc.criteria.context.Options;
12+
import org.seasar.doma.jdbc.criteria.context.InsertSettings;
1213
import org.seasar.doma.jdbc.criteria.context.SelectContext;
14+
import org.seasar.doma.jdbc.criteria.context.SelectSettings;
1315
import org.seasar.doma.jdbc.criteria.context.UpdateContext;
16+
import org.seasar.doma.jdbc.criteria.context.UpdateSettings;
1417
import org.seasar.doma.jdbc.criteria.declaration.DeleteDeclaration;
1518
import org.seasar.doma.jdbc.criteria.declaration.InsertDeclaration;
1619
import org.seasar.doma.jdbc.criteria.declaration.SelectFromDeclaration;
@@ -35,11 +38,11 @@ public <ENTITY> NativeSqlSelectStarting<ENTITY> from(EntityDef<ENTITY> entityDef
3538
}
3639

3740
public <ENTITY> NativeSqlSelectStarting<ENTITY> from(
38-
EntityDef<ENTITY> entityDef, Consumer<Options> optionsConsumer) {
41+
EntityDef<ENTITY> entityDef, Consumer<SelectSettings> settingsConsumer) {
3942
Objects.requireNonNull(entityDef);
40-
Objects.requireNonNull(optionsConsumer);
43+
Objects.requireNonNull(settingsConsumer);
4144
SelectContext context = new SelectContext(entityDef);
42-
optionsConsumer.accept(context.getOptions());
45+
settingsConsumer.accept(context.getSettings());
4346
SelectFromDeclaration declaration = new SelectFromDeclaration(context);
4447
Function<SelectQuery, ObjectProvider<ENTITY>> factory =
4548
query -> new EntityProvider<>(entityDef.asType(), query, false);
@@ -52,11 +55,11 @@ public <ENTITY> NativeSqlUpdateStarting update(EntityDef<ENTITY> entityDef) {
5255
}
5356

5457
public <ENTITY> NativeSqlUpdateStarting update(
55-
EntityDef<ENTITY> entityDef, Consumer<Options> optionsConsumer) {
58+
EntityDef<ENTITY> entityDef, Consumer<UpdateSettings> settingsConsumer) {
5659
Objects.requireNonNull(entityDef);
57-
Objects.requireNonNull(optionsConsumer);
60+
Objects.requireNonNull(settingsConsumer);
5861
UpdateContext context = new UpdateContext(entityDef);
59-
optionsConsumer.accept(context.getOptions());
62+
settingsConsumer.accept(context.getSettings());
6063
UpdateDeclaration declaration = new UpdateDeclaration(context);
6164
return new NativeSqlUpdateStarting(config, declaration);
6265
}
@@ -67,11 +70,11 @@ public <ENTITY> NativeSqlDeleteStarting delete(EntityDef<ENTITY> entityDef) {
6770
}
6871

6972
public <ENTITY> NativeSqlDeleteStarting delete(
70-
EntityDef<ENTITY> entityDef, Consumer<Options> optionsConsumer) {
73+
EntityDef<ENTITY> entityDef, Consumer<DeleteSettings> settingsConsumer) {
7174
Objects.requireNonNull(entityDef);
72-
Objects.requireNonNull(optionsConsumer);
75+
Objects.requireNonNull(settingsConsumer);
7376
DeleteContext context = new DeleteContext(entityDef);
74-
optionsConsumer.accept(context.getOptions());
77+
settingsConsumer.accept(context.getSettings());
7578
DeleteDeclaration declaration = new DeleteDeclaration(context);
7679
return new NativeSqlDeleteStarting(config, declaration);
7780
}
@@ -82,11 +85,11 @@ public <ENTITY> NativeSqlInsertStarting insert(EntityDef<ENTITY> entityDef) {
8285
}
8386

8487
public <ENTITY> NativeSqlInsertStarting insert(
85-
EntityDef<ENTITY> entityDef, Consumer<Options> optionsConsumer) {
88+
EntityDef<ENTITY> entityDef, Consumer<InsertSettings> settingsConsumer) {
8689
Objects.requireNonNull(entityDef);
87-
Objects.requireNonNull(optionsConsumer);
90+
Objects.requireNonNull(settingsConsumer);
8891
InsertContext context = new InsertContext(entityDef);
89-
optionsConsumer.accept(context.getOptions());
92+
settingsConsumer.accept(context.getSettings());
9093
InsertDeclaration declaration = new InsertDeclaration(context);
9194
return new NativeSqlInsertStarting(config, declaration);
9295
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/Context.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,5 +11,5 @@ public interface Context {
1111

1212
void setWhere(List<Criterion> where);
1313

14-
Options getOptions();
14+
Settings getSettings();
1515
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/DeleteContext.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ public class DeleteContext implements Context {
1010
public final EntityDef<?> entityDef;
1111
public final List<EntityDef<?>> entityDefs;
1212
public List<Criterion> where = new ArrayList<>();
13-
public final Options options = new Options();
13+
public final DeleteSettings options = new DeleteSettings();
1414

1515
public DeleteContext(EntityDef<?> entityDef) {
1616
Objects.requireNonNull(entityDef);
@@ -34,7 +34,7 @@ public void setWhere(List<Criterion> where) {
3434
}
3535

3636
@Override
37-
public Options getOptions() {
37+
public DeleteSettings getSettings() {
3838
return options;
3939
}
4040
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/DeleteSettings.java‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package org.seasar.doma.jdbc.criteria.context;
2+
3+
public class DeleteSettings extends Settings {
4+
int batchSize = 0;
5+
boolean allowEmptyWhere;
6+
7+
public int getBatchSize() {
8+
return batchSize;
9+
}
10+
11+
public void setBatchSize(int batchSize) {
12+
this.batchSize = batchSize;
13+
}
14+
15+
public boolean getAllowEmptyWhere() {
16+
return allowEmptyWhere;
17+
}
18+
19+
public void setAllowEmptyWhere(boolean allowEmptyWhere) {
20+
this.allowEmptyWhere = allowEmptyWhere;
21+
}
22+
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/InsertContext.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ public class InsertContext implements Context {
1111
public final EntityDef<?> entityDef;
1212
public final List<EntityDef<?>> entityDefs;
1313
public Map<Operand.Prop, Operand.Param> values = new LinkedHashMap<>();
14-
public final Options options = new Options();
14+
public final InsertSettings options = new InsertSettings();
1515

1616
public InsertContext(EntityDef<?> entityDef) {
1717
Objects.requireNonNull(entityDef);
@@ -35,7 +35,7 @@ public void setWhere(List<Criterion> where) {
3535
}
3636

3737
@Override
38-
public Options getOptions() {
38+
public InsertSettings getSettings() {
3939
return options;
4040
}
4141
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/InsertSettings.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package org.seasar.doma.jdbc.criteria.context;
2+
3+
public class InsertSettings extends Settings {
4+
int batchSize = 0;
5+
6+
public int getBatchSize() {
7+
return batchSize;
8+
}
9+
10+
public void setBatchSize(int batchSize) {
11+
this.batchSize = batchSize;
12+
}
13+
}

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/Options.java‎

Lines changed: 0 additions & 26 deletions
This file was deleted.

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/SelectContext.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ public class SelectContext implements Context {
2727
public ForUpdate forUpdate;
2828
public final Map<Pair<EntityDef<?>, EntityDef<?>>, BiConsumer<Object, Object>> associations =
2929
new LinkedHashMap<>();
30-
public final Options options = new Options();
30+
public final SelectSettings options = new SelectSettings();
3131

3232
public SelectContext(EntityDef<?> entityDef) {
3333
this(entityDef, Projection.All);
@@ -60,7 +60,7 @@ public void setWhere(List<Criterion> where) {
6060
}
6161

6262
@Override
63-
public Options getOptions() {
63+
public SelectSettings getSettings() {
6464
return options;
6565
}
6666

‎doma-core/src/main/java/org/seasar/doma/jdbc/criteria/context/SelectSettings.java‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package org.seasar.doma.jdbc.criteria.context;
2+
3+
public class SelectSettings extends Settings {
4+
private int fetchSize = 0;
5+
private int maxRows = 0;
6+
7+
public int getFetchSize() {
8+
return fetchSize;
9+
}
10+
11+
public void setFetchSize(int fetchSize) {
12+
this.fetchSize = fetchSize;
13+
}
14+
15+
public int getMaxRows() {
16+
return maxRows;
17+
}
18+
19+
public void setMaxRows(int maxRows) {
20+
this.maxRows = maxRows;
21+
}
22+
}

0 commit comments

Comments
 (0)