summaryrefslogtreecommitdiff
path: root/src/main/java/files/Database.java
diff options
context:
space:
mode:
authormavlonerkinboev <mavlonbek.ibragimov007@gmail.com>2021-08-05 19:07:22 +0500
committermavlonerkinboev <mavlonbek.ibragimov007@gmail.com>2021-08-05 19:07:22 +0500
commitadcf7dc85bd09a704e2e751256be0efa80a06760 (patch)
treeac8b7d472b68180119b60ed42b7edacc6078ac2a /src/main/java/files/Database.java
parent177553c320a8572206bd28dcb1a718b9b1192b85 (diff)
changed directory
Diffstat (limited to 'src/main/java/files/Database.java')
-rw-r--r--src/main/java/files/Database.java41
1 files changed, 0 insertions, 41 deletions
diff --git a/src/main/java/files/Database.java b/src/main/java/files/Database.java
deleted file mode 100644
index 2d35c2d..0000000
--- a/src/main/java/files/Database.java
+++ /dev/null
@@ -1,41 +0,0 @@
-package files;
-
-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 static org.fusesource.jansi.Ansi.*;
-import static org.fusesource.jansi.Ansi.Color.*;
-
-public class Database {
- private static final String MONGO_URI = Bot.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()))
- );
-
- public static void saveUser(TelegramUser telegramUser) {
- System.out.println(ansi().fg(YELLOW).a("Trying to save user to database..."));
- MongoCollection<TelegramUser> collection = database.getCollection("users", TelegramUser.class);
- System.out.println(ansi().fg(GREEN).a("Connected to database and got collection!"));
- TelegramUser searchedTelegramUser = collection.find(Filters.eq("_id", telegramUser.getId())).first();
-
- if (searchedTelegramUser == null) {
- collection.insertOne(telegramUser);
- System.out.println(ansi().fg(GREEN).a("User is added to the database!"));
- } else {
- collection.updateOne(Filters.eq("_id", telegramUser.getId()), new Document("$set", telegramUser));
- System.out.println(ansi().fg(GREEN).a("User is updated"));
- }
- }
-}