fixed: Db+Row supports Schema。

This commit is contained in:
Font_C 2023-06-02 16:50:07 +08:00
parent 9821f72fa8
commit 5791698efa
5 changed files with 14 additions and 14 deletions

View File

@ -37,11 +37,11 @@ public class DbTestStarter {
.setDataSource(dataSource)
.start();
Row row1 = Db.selectOneById("tb_account", "id", 1);
Row row1 = Db.selectOneById(null,"tb_account", "id", 1);
RowUtil.printPretty(row1);
//查询全部
List<Row> rows = Db.selectAll("tb_account");
List<Row> rows = Db.selectAll(null,"tb_account");
RowUtil.printPretty(rows);
@ -53,7 +53,7 @@ public class DbTestStarter {
row.set("user_name", "michael yang");
row.set("age", 18);
row.set("birthday", new Date());
Db.insert("tb_account", row);
Db.insert(null,"tb_account", row);
//查看刚刚插入数据的主键 id
System.out.println(">>>>>>>>>id: " + row.get("id"));
@ -79,7 +79,7 @@ public class DbTestStarter {
//再次查询全部数据
rows = Db.selectAll("tb_account");
rows = Db.selectAll(null,"tb_account");
RowUtil.printPretty(rows);
// for (Row row2 : rows) {
@ -96,10 +96,10 @@ public class DbTestStarter {
r.prepareAttrsByKeySet();
r.setPrimaryKeys(RowKey.AUTO);
});
Db.insertBatch("tb_account", rows, 100);
Db.insertBatch(null,"tb_account", rows, 100);
//再次查询全部数据
rows = Db.selectAll("tb_account");
rows = Db.selectAll(null,"tb_account");
RowUtil.printPretty(rows);
}
}

View File

@ -61,7 +61,7 @@ public class MultiDataSourceTester {
//默认查询 db1
System.out.println("\n------ds1");
List<Row> rows1 = Db.selectAll("tb_account");
List<Row> rows1 = Db.selectAll(null,"tb_account");
RowUtil.printPretty(rows1);
@ -74,7 +74,7 @@ public class MultiDataSourceTester {
// //查询数据源 ds2
System.out.println("\n------ds2");
DataSourceKey.use("ds2");
List<Row> rows = Db.selectAll("tb_account");
List<Row> rows = Db.selectAll(null,"tb_account");
RowUtil.printPretty(rows);
//
// boolean success = Db.tx(() -> {

View File

@ -50,7 +50,7 @@ public class RowTestStarter {
AuditManager.setAuditEnable(true);
AuditManager.setMessageCollector(new ConsoleMessageCollector());
Page<Row> rowPage = Db.paginate("tb_account", 1, 10, QueryWrapper.create().hint("USE_MERGE"));
Page<Row> rowPage = Db.paginate("flex","tb_account", 1, 10, QueryWrapper.create().hint("USE_MERGE"));
System.out.println(rowPage);
@ -83,13 +83,13 @@ public class RowTestStarter {
rowList.add(row);
}
Db.insertBatch("tb_account",rowList);
Db.insertBatch(null,"tb_account",rowList);
for (Row row : rowList) {
System.out.println(">>>>>>>id: " + row.get("id"));
}
List<Row> rows1 = Db.selectAll("tb_account");
List<Row> rows1 = Db.selectAll(null,"tb_account");
RowUtil.printPretty(rows1);
// //新增一条数据自增

View File

@ -73,10 +73,10 @@ public class AccountController {
// account.setUserName("heihei");
// accountMapper.update(account);
Row row1 = Db.selectOneById("tb_account", "id", 1);
Row row1 = Db.selectOneById(null,"tb_account", "id", 1);
System.out.println(">>>>>>> row1: " + row1);
Row row2 = Db.selectOneById("tb_account", "id", 2);
Row row2 = Db.selectOneById(null,"tb_account", "id", 2);
System.out.println(">>>>>>> row2: " + row2);
// Account account1 = accountMapper.selectOneById(1L);

View File

@ -41,7 +41,7 @@ public class AccountTest implements WithAssertions {
@Test
public void testSelectOneByRow() {
Row row = Db.selectOneById("tb_account", "id", 1);
Row row = Db.selectOneById(null,"tb_account", "id", 1);
System.out.println(row);
}