From eea88e5f236638862c94ce3e8cc958309a8a7d8b Mon Sep 17 00:00:00 2001 From: mavlonerkinboev Date: Thu, 26 Aug 2021 10:32:29 +0500 Subject: Change path --- .../animarfo/database/Database.java | 47 ---------------------- 1 file changed, 47 deletions(-) delete mode 100644 src/main/java/com/mavlonerkinboev/animarfo/database/Database.java (limited to 'src/main/java/com/mavlonerkinboev/animarfo/database') 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 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"); - } - } -} -- cgit v1.2.3