lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

doc

Browse Source
This commit is contained in:
redkale
2023-12-30 10:48:09 +08:00
parent 5ee14bc859
commit 4a383a9dc1
3 changed files with 67 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
docs/datasource.md
View File

@@ -61,9 +61,10 @@ redkale.datasource.platf.password = pwd123
</dependency>
```
## 增删改
## 增删改查
```java
@Data
@Table(name = "t_account")
public class Account {
//男
public static final short GENDER_MALE = 1;
@@ -115,12 +116,25 @@ public class Account {
}
```
&emsp;&emsp;删除实体：
```java
//根据主键值删除
Account account = new Account();
account.setAccountid("account1");
source.delete(account);
//过滤删除， 删除16以下男生
//等价sql: DELETE FROM t_account WHERE age < 16 AND gender = 1;
source.delete(Account.class, FilterNodes.lt(Account::getAge, 16).and("gender", GENDER_MALE));
```
&emsp;&emsp;修改实体对象：
```java
//更新单个字段
source.updateColumn(Account.class, "account1", Account::getRemark, "新备注");
//更新多个字段
//等价sql: UPDATE t_account SET account_name='新名称', remark='新备注', age=age+2 WHERE account_id='account1';
source.updateColumn(Account.class, "account1",
ColumnValue.set(Account::getAccountName, "新名称"),
ColumnValue.set(Account::getRemark, "新备注"),
@@ -133,6 +147,7 @@ public class Account {
account.setRemark("新备注");
source.updateColumn(account, "accountName", "remark");
//或者
//等价sql: UPDATE t_account SET account_name='新名称', remark='新备注' WHERE account_id='account1';
source.updateColumn(account, Account::getAccountName, Account::getRemark);
//更新整个对象
@@ -143,17 +158,28 @@ public class Account {
source.update(one); //createTime不会被更新，因字段设置了@Column(updatable=false)
//过滤更新
//等价sql: UPDATE t_account SET remark = '不满16岁是青少年' WHERE age < 16;
source.updateColumn(Account.class, FilterNodes.lt(Account::getAge, 16),
ColumnValue.set(Account::getRemark, "不满16岁是青少年"));
```
&emsp;&emsp;删除实体：
&emsp;&emsp;批量操作：
```java
Account a1 = new Account();
a1.setAccountid("account1");
a1.setAccountName("Hello1");
a1.setCreateTime(System.currentTimeMillis());
//事务性批量操作
DataBatch batch = DataBatch.create()
.insert(a1)
.updateColumn(Account.class, FilterNodes.lt(Account::getAge, 16),
ColumnValue.set(Account::getRemark, "不满16岁是青少年"))
.delete(Account.class, FilterNodes.lt(Account::getAge, 16).and("gender", GENDER_MALE));
source.batch(batch);
```
&emsp;&emsp;查询实体对象：
```java
//根据主键值删除
Account account = new Account();
account.setAccountid("account1");
source.delete(account);
//过滤删除， 删除16以下男生
source.delete(Account.class, FilterNodes.lt(Account::getAge, 16).and("gender", GENDER_MALE));
```

17
src/main/java/org/redkale/source/AbstractDataSource.java
View File

@@ -25,7 +25,6 @@ import org.redkale.persistence.Entity;
import org.redkale.service.*;
import static org.redkale.source.DataSources.*;
import org.redkale.util.*;
import org.redkale.annotation.ResourceChanged;
/**
* DataSource的S抽象实现类 <br>
@@ -1244,12 +1243,12 @@ public abstract class AbstractDataSource extends AbstractService implements Data
}
@Override
public <T> DataBatch update(Class<T> clazz, Serializable pk, String column, Serializable value) {
return update(clazz, pk, ColumnValue.set(column, value));
public <T> DataBatch updateColumn(Class<T> clazz, Serializable pk, String column, Serializable value) {
return updateColumn(clazz, pk, ColumnValue.set(column, value));
}
@Override
public <T> DataBatch update(Class<T> clazz, Serializable pk, ColumnValue... values) {
public <T> DataBatch updateColumn(Class<T> clazz, Serializable pk, ColumnValue... values) {
Objects.requireNonNull(clazz);
if (clazz.getAnnotation(Entity.class) == null) {
throw new SourceException("Entity Class " + clazz + " must be on Annotation @Entity");
@@ -1266,17 +1265,17 @@ public abstract class AbstractDataSource extends AbstractService implements Data
}
@Override
public <T> DataBatch update(Class<T> clazz, FilterNode node, String column, Serializable value) {
return update(clazz, node, (Flipper) null, ColumnValue.set(column, value));
public <T> DataBatch updateColumn(Class<T> clazz, FilterNode node, String column, Serializable value) {
return updateColumn(clazz, node, (Flipper) null, ColumnValue.set(column, value));
}
@Override
public <T> DataBatch update(Class<T> clazz, FilterNode node, ColumnValue... values) {
return update(clazz, node, (Flipper) null, values);
public <T> DataBatch updateColumn(Class<T> clazz, FilterNode node, ColumnValue... values) {
return updateColumn(clazz, node, (Flipper) null, values);
}
@Override
public <T> DataBatch update(Class<T> clazz, FilterNode node, Flipper flipper, ColumnValue... values) {
public <T> DataBatch updateColumn(Class<T> clazz, FilterNode node, Flipper flipper, ColumnValue... values) {
Objects.requireNonNull(clazz);
if (clazz.getAnnotation(Entity.class) == null) {
throw new SourceException("Entity Class " + clazz + " must be on Annotation @Entity");

31
src/main/java/org/redkale/source/DataBatch.java
View File

@@ -5,6 +5,8 @@ package org.redkale.source;
import java.io.Serializable;
import java.util.Collection;
import org.redkale.util.LambdaFunction;
import org.redkale.util.LambdaSupplier;
import org.redkale.util.SelectColumn;
/**
@@ -43,15 +45,13 @@ public interface DataBatch {
public <T> DataBatch update(Collection<T> entitys);
public <T> DataBatch update(Class<T> clazz, Serializable pk, String column, Serializable value);
public <T> DataBatch updateColumn(Class<T> clazz, Serializable pk, String column, Serializable value);
public <T> DataBatch update(Class<T> clazz, Serializable pk, ColumnValue... values);
public <T> DataBatch updateColumn(Class<T> clazz, Serializable pk, ColumnValue... values);
public <T> DataBatch update(Class<T> clazz, FilterNode node, String column, Serializable value);
public <T> DataBatch updateColumn(Class<T> clazz, FilterNode node, String column, Serializable value);
public <T> DataBatch update(Class<T> clazz, FilterNode node, ColumnValue... values);
public <T> DataBatch update(Class<T> clazz, FilterNode node, Flipper flipper, ColumnValue... values);
public <T> DataBatch updateColumn(Class<T> clazz, FilterNode node, Flipper flipper, ColumnValue... values);
public <T> DataBatch updateColumn(T entity, final String... columns);
@@ -61,4 +61,23 @@ public interface DataBatch {
public <T> DataBatch updateColumn(T entity, final FilterNode node, SelectColumn selects);
default <T, V extends Serializable> DataBatch updateColumn(final Class<T> clazz, final Serializable pk, final LambdaSupplier<V> func) {
return updateColumn(clazz, pk, LambdaSupplier.readColumn(func), func.get());
}
default <T> DataBatch updateColumn(final Class<T> clazz, final Serializable pk, LambdaFunction<T, ?> func, Serializable value) {
return updateColumn(clazz, pk, ColumnValue.set(func, value));
}
default <T> DataBatch updateColumn(final Class<T> clazz, final FilterNode node, final ColumnValue... values) {
return updateColumn(clazz, node, (Flipper) null, values);
}
default <T> DataBatch updateColumn(final T entity, final LambdaFunction<T, ?>... funcs) {
return updateColumn(entity, (FilterNode) null, LambdaFunction.readColumns(funcs));
}
default <T> DataBatch updateColumn(final T entity, final FilterNode node, final LambdaFunction<T, ?>... funcs) {
return updateColumn(entity, node, LambdaFunction.readColumns(funcs));
}
}