同步操作将从 JbootProjects/jboot 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
Jboot 数据库功能基于 JFinal 的 ActiveRecordPlugin 插件和 Apache sharding-sphere 框架,提供了方便快捷的数据库操作能力。
Jboot 的数据库是依赖 JFinal 的 ORM 做基本的数据库操作,同时依赖 apahce-sphere 来做分库、分表和分布式事务。
因此,在使用 Jboot 操作数据库的时候,建议对 JFinal 的 ORM 功能和 Apache Sharding-Sphere 有所了解。
JFinal 操作数据库,提供了两种方式对数据库进行操作,他们分别是:
Db 可以理解为一个工具类,而 Record 是一个类似 Map 的数据结构(其实内部就是通过 Map 来实现的),Db 查询的返回的数据是一个 Record
或者是 List<Record>
, Db 提供了如下操作数据库的系列方法:
方法 | 描述 |
---|---|
query(String, Object...) | ... |
query(String) | ... |
queryFirst(String, Object...) | ... |
queryFirst(String) | ... |
queryColumn(String, Object...) | ... |
queryColumn(String) | ... |
queryStr(String, Object...) | ... |
queryStr(String) | ... |
queryInt(String, Object...) | ... |
queryInt(String) | ... |
queryLong(String, Object...) | ... |
queryLong(String) | ... |
queryDouble(String, Object...) | |
queryDouble(String) | ... |
queryFloat(String, Object...) | ... |
queryFloat(String) | ... |
queryBigDecimal(String, Object...) | ... |
queryBigDecimal(String) | ... |
queryBytes(String, Object...) | ... |
queryBytes(String) | ... |
queryDate(String, Object...) | ... |
queryDate(String) | ... |
queryTime(String, Object...) | ... |
queryTime(String) | ... |
queryTimestamp(String, Object...) | ... |
queryTimestamp(String) | ... |
queryBoolean(String, Object...) | ... |
queryBoolean(String) | ... |
queryShort(String, Object...) | ... |
queryShort(String) | ... |
queryByte(String, Object...) | ... |
queryByte(String) | ... |
queryNumber(String, Object...) | ... |
queryNumber(String) | ... |
update(String, Object...) | ... |
update(String) | ... |
find(String, Object...) | ... |
find(String) | ... |
findFirst(String, Object...) | ... |
findFirst(String) | ... |
findById(String, Object) | ... |
findById(String, String, Object...) | ... |
deleteById(String, Object) | ... |
deleteById(String, String, Object...) | ... |
delete(String, String, Record) | ... |
delete(String, Record) | ... |
delete(String, Object...) | ... |
delete(String) | ... |
paginate(int, int, String, String, Object...) | ... |
paginate(int, int, boolean, String, String, Object...) | ... |
paginate(int, int, String, String) | ... |
paginateByFullSql(int, int, String, String, Object...) | ... |
paginateByFullSql(int, int, boolean, String, String, Object...) | ... |
save(Config, java.sql.Connection, String, String, Record) | ... |
save(String, String, Record) | ... |
save(String, Record) | ... |
update(Config, java.sql.Connection, String, String, Record) | ... |
update(String, String, Record) | ... |
update(String, Record) | ... |
execute(ICallback) | ... |
execute(Config, ICallback) | ... |
tx(Config, int, IAtom) | ... |
tx(int, IAtom) | ... |
tx(IAtom) | ... |
findByCache(String, Object, String, Object...) | ... |
findByCache(String, Object, String) | ... |
findFirstByCache(String, Object, String, Object...) | ... |
findFirstByCache(String, Object, String) | ... |
paginateByCache(String, Object, int, int, String, String, Object...) | ... |
paginateByCache(String, Object, int, int, boolean, String, String, Object...) | ... |
paginateByCache(String, Object, int, int, String, String) | ... |
batch(String, Object[][], int) | ... |
batch(String, String, List, int) | ... |
batch(List, int) | ... |
batchSave(List<? extends Model>, int) | ... |
batchSave(String, List, int) | ... |
batchUpdate(List<? extends Model>, int) | ... |
batchUpdate(String, String, List, int) | ... |
batchUpdate(String, List, int) | ... |
getSql | ... |
getSqlPara(String, Record) | ... |
getSqlPara(String, Model) | ... |
getSqlPara(String, Map) | ... |
getSqlPara(String, Object...) | ... |
find(SqlPara) | ... |
findFirst(SqlPara) | ... |
update(SqlPara) | ... |
paginate(int, int, SqlPara) | ... |
以下是 Db + Record 模式的一些示例:
// 创建name属性为James,age属性为25的record对象并添加到数据库
Record user = new Record()
.set("name", "James")
.set("age", 25);
Db.save("user", user);
// 删除id值为25的user表中的记录
Db.deleteById("user", 25);
// 查询id值为25的Record将其name属性改为James并更新到数据库
user = Db.findById("user", 25).set("name", "James");
Db.update("user", user);
// 获取user的name属性
String userName = user.getStr("name");
// 获取user的age属性
Integer userAge = user.getInt("age");
// 查询所有年龄大于18岁的user
List<Record> users = Db.find("select * from user where age > 18");
// 分页查询年龄大于18的user,当前页号为1,每页10个user
Page<Record> userPage = Db.paginate(1, 10, "select *", "from user where age > ?", 18);
在单数据库下,以下是 Db 工具进行的事务操作:
boolean succeed = Db.tx(() -> {
int count = Db.update("update account set cash = cash - ? where id = ?", 100, 123);
int count2 = Db.update("update account set cash = cash + ? where id = ?", 100, 456);
return count == 1 && count2 == 1;
});
以上两次数据库更新操作在一个事务中执行,如果执行过程中发生异常或者return false,则自动回滚事务。
Model是 MVC 模式中的 M 部分。以下是 Model 定义示例代码:
@Table(tableName = "user", primaryKey = "id")
public class User extends BaseUser<User> {
}
BaseUser:
public abstract class BaseUser<M extends BaseUser<M>> extends JbootModel<M> implements IBean {
public void setId(java.lang.Long id) {
set("id", id);
}
public java.lang.Long getId() {
return getLong("id");
}
// other getter setter ...
}
需要注意的是:
User
和 BaseUser
都是通过代码生成器自动生成的,无需手写。User
代码不会被覆盖,但是 BaseUser
会被重新覆盖,因此,请不要在 BaseUser
手写任何代码。一般情况下,在正式的项目里,代码分层还需要 Service
层来对业务逻辑进行处理。
UserService 代码如下:
public class UserService extends JbootServiceBase<User> {
// 不需要做任何的实现
}
以上的 UserService
, 只需要继承 JbootServiceBase<User>
,我们不需要编写任何实现代码,就可以拥有基本的增删改查的功能。
以下是示例代码:
//创建 UserService
UserService userService = new UserService();
// 创建name属性为James,age属性为25的User对象并添加到数据库
User user = new User().set("name", "James").set("age", 25);
userService.save(user);
// 删除id值为25的User
userService.deleteById(25);
// 查询id值为25的User将其name属性改为James并更新到数据库
User user = userService.findById(25);
user.set("name", "James");
userService.update(user);
// 分页查询user,当前页号为1,每页10个user
Page<User> userPage = userService.paginate(1, 10);
在 Jboot 应用中,读写分离建议使用两个数据源,分别是读的数据源和写的数据源,写的数据源必须支持可读可写。
在应用中,在某些场景下我们需要从只读数据源读取数据的时候,通过 DAO.use('只读数据源的名称').find(...)
就可以。
Jboot 的分库分表功能使用了 Sharding-jdbc 实现的,若在 Jboot 应用在需要用到分库分表功能,需要添加 jboot.datasource.shardingConfigYaml = xxx.yaml
的配置,其中 xxx.yaml
配置需要放在 classpath 目录下,配置内容参考:https://shardingsphere.apache.org/document/current/cn/manual/sharding-jdbc/configuration/config-yaml/
注意: 当在 jboot.properties
文件配置 jboot.datasource.shardingConfigYaml = xxx.yaml
之后,不再需要在 jboot.properties
配置 jboot.datasource.url
、 jboot.datasource.user
和 jboot.datasource.password
等,这些配置都转义到 xxx.yaml
里进行配置了。
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。