Cet article implémente une classe générale d'implémentation d'encapsulation générique, qui nécessite un objet de collection donné, similaire à la table correspondant à Java dans MySQL ; l'idée est d'analyser tous les champs non vides de l'objet donné et de les enregistrer dans un BasicDBObject, ici Assurez-vous que l'objet Java porte le même nom que le champ de document dans mongodb, car afin d'atteindre l'universalité, le code par défaut est le champ de requête de l'objet Java en tant que BasicDBObject.
Code principal 1 : il s'agit de convertir les objets Java en conditions de requête.
/**
* 通过反射获取非空字段信息
* @param record
* @param <Q>
* @return
*/
private <Q> BasicDBObject getCondition(Q record) {
BasicDBObject cond = new BasicDBObject();
Class clazz = record.getClass();
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
try {
field.setAccessible(true);
Object value = field.get(record);
if (value != null)
cond.put(field.getName(), value);
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
return cond;
}Code de base 2 : Il s'agit de convertir le document interrogé en un objet Java. Ici, les champs de l'objet Java par défaut sont les mêmes que les champs du document de base de données. obtenu dynamiquement à l'aide de la réflexion Java. Tous les champs sont ensuite attribués. J'ai jugé les types int et long séparément pendant le processus d'affectation, car lors de l'insertion dans mongodb, ils sont généralement stockés en double, ce qui provoquera une erreur de transformation.
/**
* 将结果转化为自定义对象
* @param document
* @param target
* @param <Q>
* @return
*/
private <Q> Q parseToObject(Document document, Class<Q> target) {
try {
Q result = target.newInstance();
Field[] fields = target.getDeclaredFields();
for (Field f : fields) {
f.setAccessible(true);
Object value = document.get(f.getName());
if (value == null)
continue;
else if (f.getType() == Integer.class)
f.set(result, ((Number) value).intValue());
else if (f.getType() == Long.class)
f.set(result, ((Number) value).longValue());
else
f.set(result, document.get(f.getName(), f.getType()));
}
return result;
} catch (IllegalAccessException e) {
e.printStackTrace();
return null;
} catch (InstantiationException e) {
e.printStackTrace();
return null;
}
}Méthode d'appel : convertissez d'abord les paramètres de requête. Lors de l'interrogation, l'identifiant est utilisé pour déterminer l'ordre positif et négatif, la base de données par défaut doit donc avoir un champ d'identification d'identifiant.
public <Q> List<Q> queryByCondition(BaseQuery<Q> query,boolean up) {
Q record = query.getQuery();
BasicDBObject cond = getCondition(record);
FindIterable<Document> findIterable;
if (query.getStart() != null && query.getRows() != null)
findIterable = thisCollection().find(cond)
.sort(new BasicDBObject("id", up ? 1 : -1))
.skip((query.getStart() - 1) * query.getRows())
.limit(query.getRows());
else
findIterable = thisCollection().find(cond)
.sort(new BasicDBObject("id", up ? 1 : -1));
MongoCursor<Document> iterator = findIterable.iterator();
List<Q> result = new ArrayList<>();
while (iterator.hasNext()) {
Document document = iterator.next();
result.add((Q) parseToObject(document, record.getClass()));
}
iterator.close();
return result;
}La BaseQuery transmise ici est la suivante : la requête à l'intérieur est un objet Java qui doit être interrogé, et start&rows est utilisé pour la pagination. Le plug-in lombok est utilisé ici, ce qui simplifie beaucoup de codes gettter&setter et autres.
@Setter
@Getter
@NoArgsConstructor
@AllArgsConstructor
@Data
@Accessors(chain = true)
public class BaseQuery<Q> {
private Integer start;
private Integer rows;
private Q query;
public BaseQuery(Class clazz) {
try {
this.query = (Q) clazz.newInstance();
} catch (InstantiationException e) {
e.printStackTrace();
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
}Méthode de requête de condition de test : Les entités utilisées ici sont les suivantes :
@Data
@AllArgsConstructor
@NoArgsConstructor
@Accessors(chain = true)
public class User_info {
private Integer id;
private String name;
private Integer age;
private Integer role;
}public static void main(String[] args) {
User_info record = new User_info();
BaseQuery<User_info> query = new BaseQuery<>();
query.setQuery(record);
BaseMongoDao dao = new BaseMongoDao("test");
List<User_info> result = dao.queryByCondition(query, true);
for (User_info user : result) {
System.out.println(user);
}
}Les conditions de requête utilisées ici étant vides, tous les éléments de la base de données seront correspondant. :
Testez maintenant les données avec l'autorisation définie sur 1 :
public static void main(String[] args) {
User_info record = new User_info();
record.setRole(1);
BaseQuery<User_info> query = new BaseQuery<>();
query.setQuery(record);
BaseMongoDao dao = new BaseMongoDao("test");
List<User_info> result = dao.queryByCondition(query, true);
for (User_info user : result) {
System.out.println(user);
}
}Sortie :
Cette méthode de requête conditionnelle est un exemple. D'autres suppressions, ajouts et modifications sont basés sur ce principe :
1. Q>, booléen vers le haut)
2.public Integer queryCoditionCount (BaseQuery
requête)
3.public >
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
