andreacavalli/rockserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Restore columnId without getting it first

Browse Source
This commit is contained in:
Andrea Cavalli 2024-03-30 02:57:32 +01:00
parent bb9e9ad33c
commit 9729704bb9
1 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/it/cavallium/rockserver/core/Migrate.java
View File

@ -63,15 +63,7 @@ public class Migrate {
System.out.println("parsed documents"); System.out.println("parsed documents");
var protocol = new TBinaryProtocol(transport); var protocol = new TBinaryProtocol(transport);
var client = new RocksDB.Client(protocol); var client = new RocksDB.Client(protocol);
long columnId; long columnId = client.createColumn(columnName, columnSchema);
long tmpColumnId;
try {
tmpColumnId = client.getColumnId(columnName);
} catch (TApplicationException ex) {
tmpColumnId = client.createColumn(columnName, columnSchema);
}
columnId = tmpColumnId;
var encoder = new BasicBSONEncoder(); var encoder = new BasicBSONEncoder();
long nn = 0; long nn = 0;
long total = documentMap.size(); long total = documentMap.size();