MongoDB هو منتج بين قاعدة بيانات علائقية وقاعدة بيانات غير علمية. تنسيق تخزين الملف هو BSON (امتداد JSON). هنا نقدم بشكل أساسي Java لتنفيذ مجموعة اتصال MongoDB باستخدام حزمة Mongo-2.7.3.jar. تطبيق رمز Java المحدد هو كما يلي:
معلمات تكوين تجمعات اتصال قاعدة البيانات:
/ ***@الوصف: ملف تكوين تجمع Mongo Connection*/ package cn.lulei.mongo.pool ؛ الفئة العامة mongoconfig {private static string username ؛ // username private static string pwd ؛ // password private static string [] 10 ؛ // عدد قوائم قوائم قوائم الخيوط الخاصة مصادقة منطقية ثابتة = false ؛ // هي المصادقة المطلوبة من سلسلة ثابتة عامة getUsername () {return username ؛ } setusername الفراغ الثابت (اسم المستخدم) {mongoconfig.username = username ؛ } سلسلة ثابتة عامة getPwd () {return pwd ؛ } public static void setpwd (سلسلة pwd) {mongoconfig.pwd = pwd ؛ } سلسلة ثابتة عامة [] gethost () {return host ؛ } public static void sethost (string [] host) {mongoconfig.host = host ؛ } int static int [] getPort () {return port ؛ } public static void setport (int [] port) {mongoconfig.port = port ؛ } سلسلة ثابتة عامة getDbName () {return dbname ؛ } public static void setDbName (String dbname) {mongoconfig.dbname = dbname ؛ } static int getConnectionSperHost () {return connecteSperHost ؛ } setConnectionSperHost static static void (int connecteSperHost) {mongoconfig.connectionSperHost = connectionSperHost ؛ } int int int int inthreadsallyedtoBlockForConnectionMultiplier () {return threadsallydtoBlockForConnectionMultiplier ؛ } setThReadSally static static voidsallydtoBlockForConnectionMultiPlier (int threadsallyedtoBlockForConnectionMultiPlier) {mongoconfig.ThreadSallOldToBlockForConnectionMultiPlier = threadsallydoolockedToBlockForConnectionMultiplier ؛ } isauthentication الثابتة العامة الثابتة () {return مصادقة ؛ } setAuthentication الفاخرة الثابتة (مصادقة منطقية) {mongoconfig.authentication = المصادقة ؛ }} فئة إدارة تجمع اتصالات قاعدة البيانات:
/ ***@الوصف: فئة إدارة اتصالات قاعدة بيانات Mongo*/ Package Cn.Lulei.Mongo.pool ؛ استيراد java.util.arraylist ؛ استيراد java.util.list ؛ استيراد com.mongodb.db ؛ استيراد com.mongodb.dbcollection ؛ استيراد com.mongodb.mongo ؛ استيراد com.mongodb.mongooptions ؛ استيراد com.mongodb.ReadPreference ؛ استيراد com.mongodb.serveraddress ؛ الطبقة العامة mongomanager {private static mongo mongo ؛ خاص DB DB ؛ ثابت {init () ؛ } / ** * param dbname * param username * param pwd * instantiate dbname a db * / public mongomanager (String dbname ، string username ، string pwd) {if (dbname == null || } db = mongo.getdb (dbname) ؛ if (mongoconfig.isauthentication () &&! db.isauthenticated ()) {if (username == null || ".equals (username)) {throw numberformatexception (" username is null ") ؛ } if (pwd == null || ". } db.Authenticate (اسم المستخدم ، pwd.tochararray ()) ؛ }} / *** instantiate باستخدام معلمات التكوين* / public mongomanager () {this (mongoconfig.getdbname () ، mongoconfig.getusername () ، mongoconfig.getpwd ()) ؛ } / ** * param tablename * return * description: احصل على الرابط إلى tableName dbCollection * / public dbCollection getDbCollection (سلسلة tablename) {return db.getCollection (tablename) ؛ } / *** description: تهيئة تجمعات الاتصال Mongo* / private static void init () {if (mongoconfig.gethost () == null || mongoconfig.gethost (). length == 0) {throw numbertordexception ("host is null") ؛ } if (mongoconfig.getport () == null || mongoconfig.getport (). length == 0) {رمي numberformatexception ("المنفذ فارغ") ؛ } if (mongoconfig.gethost (). الطول! = mongoconfig.getport () } جرب {// قائمة قائمة Service <ServerAdDress> REPLICASETSEEDS = ARRAYLIST جديد <ServerAdDress> () ؛ من أجل (int i = 0 ؛ i <mongoconfig.gethost () } // إعدادات تجمعات الاتصال خيارات mongooptions = mongooptions جديدة () ؛ Options.ConnectionSperHost = mongoconfig.getConnectionSperHost () ؛ Options.ThreadSallOllOctBlockForConnectionMultiPlier = mongoconfig.getThReadSallOldToBlockForConnectionMultiPlier () ؛ mongo = new mongo (remlicasetseeds ، الخيارات) ؛ // قابلة للقراءة من الخادم mongo.setReadPreference (retpreference.Secondary) ؛ } catch (استثناء e) {E.PrintStackTrace () ؛ }}} دعونا نلقي نظرة على كيفية استخدام تجمع الاتصال هذا من خلال فئة اختبار بسيطة ~
/ ***@الوصف: Mongo test*/ package cn.lulei.mongo.test ؛ استيراد cn.lulei.mongo.pool.mongoconfig ؛ استيراد cn.lulei.mongo.pool.mongomanager ؛ اختبار الفئة العامة {public static void main (string [] args) {// todo method method method method string [] host = {"127.0.0.1"} ؛ int [] port = {27001} ؛ mongoconfig.sethost (مضيف) ؛ mongoconfig.setport (port) ؛ mongoconfig.setdbname ("Novel") ؛ mongomanager mongomanager = new mongomanager () ؛ mongomanager.getdbcollection ("الفصل") ؛ }}عند استخدام فئة الإدارة أعلاه ، تحتاج فقط إلى تهيئة فئة MongoconFig. بالنسبة لحالات Mongomanager ، يمكنك استخدام تكوين MongoconFig أو تعيينه بنفسك. في كل مرة تحصل فيها على DBCollection ، تحتاج فقط إلى استدعاء طريقة getDBCollection (سلسلة tablename).
ما سبق هو كل شيء عن هذا المقال. آمل أن يكون الوصف في هذه المقالة مفيدًا للجميع لتعلم برمجة Java.