diff options
author | mavlonerkinboev <mavlonbek.ibragimov007@gmail.com> | 2021-08-05 19:07:22 +0500 |
---|---|---|
committer | mavlonerkinboev <mavlonbek.ibragimov007@gmail.com> | 2021-08-05 19:07:22 +0500 |
commit | adcf7dc85bd09a704e2e751256be0efa80a06760 (patch) | |
tree | ac8b7d472b68180119b60ed42b7edacc6078ac2a /src/main/java/files/Database.java | |
parent | 177553c320a8572206bd28dcb1a718b9b1192b85 (diff) |
changed directory
Diffstat (limited to 'src/main/java/files/Database.java')
-rw-r--r-- | src/main/java/files/Database.java | 41 |
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")); - } - } -} |