IT4Change/gradido
3
0
Fork 0
mirror of https://github.com/IT4Change/gradido.git synced 2026-03-01 12:44:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

sort rows from db additional by id if the dates are the same because of faster seeding

Browse Source
This commit is contained in:
einhornimmond 2025-12-04 08:29:34 +01:00
parent dc8a8181b4
commit 59b78766ee
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dlt-connector/src/migrations/db-v2.7.0_to_blockchain-v3.5/database.ts
View File

@ -40,6 +40,7 @@ export async function loadCommunities(db: MySql2Database): Promise<CommunityDb[]
.from(communitiesTable)
.leftJoin(usersTable, eq(communitiesTable.communityUuid, usersTable.communityUuid))
.where(isNotNull(communitiesTable.communityUuid))
.orderBy(asc(communitiesTable.id))
.groupBy(communitiesTable.communityUuid)
const communityNames = new Set<string>()
@ -65,7 +66,7 @@ export async function loadUsers(
const result = await db
.select()
.from(usersTable)
.orderBy(asc(usersTable.createdAt))
.orderBy(asc(usersTable.createdAt), asc(usersTable.id))
.limit(count)
.offset(offset)
@ -98,7 +99,7 @@ export async function loadTransactions(
transactionLinksTable,
eq(transactionsTable.transactionLinkId, transactionLinksTable.id),
)
.orderBy(asc(transactionsTable.balanceDate))
.orderBy(asc(transactionsTable.balanceDate), asc(transactionsTable.id))
.limit(count)
.offset(offset)
@ -148,7 +149,7 @@ export async function loadTransactionLinks(
.select()
.from(transactionLinksTable)
.leftJoin(usersTable, eq(transactionLinksTable.userId, usersTable.id))
.orderBy(asc(transactionLinksTable.createdAt))
.orderBy(asc(transactionLinksTable.createdAt), asc(transactionLinksTable.id))
.limit(count)
.offset(offset)
@ -170,7 +171,7 @@ export async function loadDeletedTransactionLinks(
.from(transactionLinksTable)
.leftJoin(usersTable, eq(transactionLinksTable.userId, usersTable.id))
.where(isNotNull(transactionLinksTable.deletedAt))
.orderBy(asc(transactionLinksTable.deletedAt))
.orderBy(asc(transactionLinksTable.deletedAt), asc(transactionLinksTable.id))
.limit(count)
.offset(offset)

1
dlt-connector/src/migrations/db-v2.7.0_to_blockchain-v3.5/drizzle.schema.ts
View File

@ -15,6 +15,7 @@ import {
export const communitiesTable = mysqlTable(
'communities',
{
id: int().autoincrement().notNull(),
foreign: tinyint().default(1).notNull(),
communityUuid: char('community_uuid', { length: 36 }).default(sql`NULL`),
name: varchar({ length: 40 }).default(sql`NULL`),