summaryrefslogtreecommitdiff
path: root/src/main/java/com/mavlonerkinboev/animarfo/database
diff options
context:
space:
mode:
authormavlonerkinboev <mavlonbek.ibragimov007@gmail.com>2021-08-26 10:32:29 +0500
committermavlonerkinboev <mavlonbek.ibragimov007@gmail.com>2021-08-26 10:32:29 +0500
commiteea88e5f236638862c94ce3e8cc958309a8a7d8b (patch)
treef26c76f224673ce07d334f73a908ff575e119cb1 /src/main/java/com/mavlonerkinboev/animarfo/database
parent59f54892f90eda23bcca45cc07d466c105db75ef (diff)
Change path
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");
- }
- }
-}