kangaroo-and-rabbit/archidata
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[FEAT] add clean on Mongo

Browse Source
This commit is contained in:
Edouard DUPIN 2024-10-14 20:15:14 +02:00
parent c1e9b4bb4c
commit 507c2299da
2 changed files with 7 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

65
src/org/kar/archidata/dataAccess/DataAccessMorphia.java
View File

@ -1259,74 +1259,17 @@ public class DataAccessMorphia extends DataAccess {
@Override
public void drop(final Class<?> clazz, final QueryOption... option) throws Exception {
/*
final QueryOptions options = new QueryOptions(option);
final String collectionName = AnnotationTools.getCollectionName(clazz, options);
final DBEntry entry = DBInterfaceOption.getAutoEntry(options);
final StringBuilder query = new StringBuilder();
query.append("DROP TABLE IF EXISTS `");
query.append(tableName);
query.append("`");
try {
LOGGER.trace("Execute Query: {}", query.toString());
// Remove main table
final PreparedStatement ps = entry.connection.prepareStatement(query.toString());
ps.executeUpdate();
// search subTable:
for (final Field field : clazz.getFields()) {
// static field is only for internal global declaration ==> remove it ..
if (java.lang.reflect.Modifier.isStatic(field.getModifiers())) {
continue;
}
if (AnnotationTools.isGenericField(field)) {
continue;
}
final DataAccessAddOn addOn = findAddOnforField(field);
if (addOn != null && !addOn.canInsert(field)) {
LOGGER.error("TODO: Add on not managed ... ");
//addOn.drop(tableName, field);
}
}
} finally {
entry.close();
}
*/
final MongoCollection<Document> collection = this.db.getDatastore().getDatabase().getCollection(collectionName);
collection.drop();
}
@Override
public void cleanAll(final Class<?> clazz, final QueryOption... option) throws Exception {
/*
final QueryOptions options = new QueryOptions(option);
final String collectionName = AnnotationTools.getCollectionName(clazz, options);
DBEntry entry = DBInterfaceOption.getAutoEntry(options);
final StringBuilder query = new StringBuilder();
query.append("DELETE FROM `");
query.append(tableName);
query.append("`");
try {
LOGGER.trace("Execute Query: {}", query.toString());
// Remove main table
final PreparedStatement ps = entry.connection.prepareStatement(query.toString());
ps.executeUpdate();
// search subTable:
for (final Field field : clazz.getFields()) {
// static field is only for internal global declaration ==> remove it ..
if (java.lang.reflect.Modifier.isStatic(field.getModifiers())) {
continue;
}
if (AnnotationTools.isGenericField(field)) {
continue;
}
final DataAccessAddOn addOn = findAddOnforField(field);
if (addOn != null && !addOn.canInsert(field)) {
LOGGER.error("TODO: Add on not managed ... ");
//addOn.cleanAll(tableName, field);
}
}
} finally {
entry.close();
entry = null;
}
*/
final MongoCollection<Document> collection = this.db.getDatastore().getDatabase().getCollection(collectionName);
collection.deleteMany(new Document());
}
}

3
test/src/test/kar/archidata/ConfigureDb.java
View File

@ -3,6 +3,7 @@ package test.kar.archidata;
import java.io.IOException;
import org.kar.archidata.GlobalConfiguration;
import org.kar.archidata.dataAccess.DataAccess;
import org.kar.archidata.db.DBEntry;
import org.kar.archidata.tools.ConfigBaseVariable;
import org.slf4j.Logger;
@ -52,6 +53,8 @@ public class ConfigureDb {
public static void clear() throws IOException {
LOGGER.info("Remove the test db");
final DataAccess da = DataAccess.createInterface();
//da.cleanAll(null, null);
DBEntry.closeAllForceMode();
ConfigBaseVariable.clearAllValue();