summaryrefslogtreecommitdiff
path: root/src/main/java/com/mavlonerkinboev/animarfo/database
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/mavlonerkinboev/animarfo/database')
-rw-r--r--src/main/java/com/mavlonerkinboev/animarfo/database/Database.java47
1 files changed, 0 insertions, 47 deletions
diff --git a/src/main/java/com/mavlonerkinboev/animarfo/database/Database.java b/src/main/java/com/mavlonerkinboev/animarfo/database/Database.java
deleted file mode 100644
index 4b5a11f..0000000
--- a/src/main/java/com/mavlonerkinboev/animarfo/database/Database.java
+++ /dev/null
@@ -1,47 +0,0 @@
-package com.mavlonerkinboev.animarfo.database;
-
-import com.mavlonerkinboev.animarfo.App;
-import com.mavlonerkinboev.animarfo.telegram.user.TelegramUser;
-import com.mongodb.MongoClient;
-import com.mongodb.MongoClientSettings;
-import com.mongodb.MongoClientURI;
-import com.mongodb.client.MongoCollection;
-import com.mongodb.client.MongoDatabase;
-import com.mongodb.client.model.Filters;
-import org.bson.Document;
-import org.bson.codecs.configuration.CodecRegistries;
-import org.bson.codecs.pojo.PojoCodecProvider;
-
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-public class Database {
- private static final String MONGO_URI = App.PROPERTIES.getProperty("DATABASE_URL");
- private static final MongoDatabase database = new MongoClient(new MongoClientURI(MONGO_URI))
- .getDatabase("animarfo")
- .withCodecRegistry(
- CodecRegistries.fromRegistries(
- MongoClientSettings.getDefaultCodecRegistry(),
- CodecRegistries.fromProviders(PojoCodecProvider.builder().automatic(true).build())
- )
- );
- private static final Logger LOGGER = Logger.getLogger(Database.class.getName());
- static {
- LOGGER.setLevel(Level.ALL);
- }
-
- public static void saveUser(TelegramUser telegramUser) {
- LOGGER.info("Trying to save user to database");
- MongoCollection<TelegramUser> collection = database.getCollection("users", TelegramUser.class);
- LOGGER.fine("Connected to database and got collection");
- TelegramUser searchedTelegramUser = collection.find(Filters.eq("_id", telegramUser.getId())).first();
-
- if (searchedTelegramUser == null) {
- collection.insertOne(telegramUser);
- LOGGER.fine("User is added to the database");
- } else {
- collection.updateOne(Filters.eq("_id", telegramUser.getId()), new Document("$set", telegramUser));
- LOGGER.fine("User is updated");
- }
- }
-}