怎么在Android中连接MongoDB数据库?针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
MongoDB简介
Mongodb,分布式文档存储数据库,由C++语言编写,旨在为WEB应用提供可扩展的高性能数据存储解决方案。MongoDB是一个高性能,开源,无模式的文档型数据库,是当前NoSql数据库中比较热门的一种。它在许多场景下可用于替代传统的关系型数据库或键/值存储方式。Mongo使用C++开发。
Mongo安装参考
1)下载安装包文件,解压到某一文件夹下。
官方下载地址:http://www.mongodb.org/downloads
2)配置环境变量:在path后添加安装路径。
3)启动Mongo数据库:
进入“cmd”->键入“mongod --dbpath D:\amp\MongoDBDATA”
D:\amp\MongoDBDATA 表示数据库文件存储路径
4)启动Mongo客户端:
mongo 127.0.0.1:27017/admin
Android 连接MongoDB
步骤1:下载并导入jar包到工程
步骤2:安装MongoDB到PC端(参见MongoDB安装)
步骤3:编写代码连接MongoDB实现简单操作(增删改查)
代码参考(Android端,也适用于java等工程)
MongoDBUtil.java
package com.hills.happytest.utils;import java.util.List;import org.bson.types.ObjectId;import com.mongodb.BasicDBObject;import com.mongodb.DB;import com.mongodb.DBCollection;import com.mongodb.DBCursor;import com.mongodb.DBObject;import com.mongodb.Mongo;public class MongoDBUtil { static Mongo connection = null; static DB db = null; public MongoDBUtil(String dbName) throws Exception { connection = new Mongo("10.0.2.2:27017"); db = connection.getDB(dbName); } public static Mongo getConnection() { return connection; } public void createCollection(String collName) { DBObject dbs = new BasicDBObject(); dbs.put("test", "test"); db.createCollection(collName, dbs); } public void insert(DBObject dbObject,String collName) { DBCollection collection = db.getCollection(collName); collection.insert(dbObject); } public void insertBatch(List<DBObject> dbObjects,String collName) { DBCollection collection = db.getCollection(collName); collection.insert(dbObjects); } public int deleteById(String id,String collName) { DBCollection collection = db.getCollection(collName); DBObject dbs = new BasicDBObject("_id", new ObjectId(id)); int counts = collection.remove(dbs).getN(); return counts; } public int deleteByDbs(DBObject dbObject,String collName) { DBCollection collection = db.getCollection(collName); int count = collection.remove(dbObject).getN(); return count; } public int update(DBObject find,DBObject update,boolean upsert,boolean multi,String collName) { DBCollection collection = db.getCollection(collName); int count = collection.update(find, update, upsert, multi).getN(); return count; } public DBCursor findWithPage(DBObject where,DBObject selection,int start,int limit,String collName) { DBCursor cursor = findNoPage(where, selection, collName); return cursor.limit(limit).skip(start); } public DBCursor findNoPage(DBObject where,DBObject selection,String collName) { DBCollection collection = db.getCollection(collName); DBCursor cursor = collection.find(where, selection); return cursor; }}
MongoDBDao.java
package com.hills.happytest.utils;import java.util.ArrayList;import java.util.List;import com.mongodb.BasicDBObject;import com.mongodb.DBCursor;import com.mongodb.DBObject;public class MongoDBDao { private static MongoDBUtil mongoDb; // Init. MongoDBUtil. static{ try { mongoDb = new MongoDBUtil("test"); } catch (Exception e) { e.printStackTrace(); } } public void createCollectionTest(String collName) { mongoDb.createCollection(collName); } public void insertTest(String collName) { DBObject dbs = new BasicDBObject(); dbs.put("name", "gymyung"); dbs.put("age", 20); List<String> books = new ArrayList<String>(); books.add("EXTJS"); books.add("MONGDB"); books.add("JAVA"); dbs.put("books", books); mongoDb.insert(dbs, collName); } public void insertBatchTest(String collName) { List<DBObject> dbObjects = new ArrayList<DBObject>(); DBObject jim2 = new BasicDBObject("name", "jim2"); DBObject liuting = new BasicDBObject(); liuting.put("name", "liuting"); liuting.put("age", "22"); dbObjects.add(jim2); dbObjects.add(liuting); mongoDb.insertBatch(dbObjects, collName); } public int deleteByIdTest(String collName) { int counts = mongoDb.deleteById("54507d19cbbd7a385c129ef5", collName); return counts; } public int deleteByDbsTest(String collName) { DBObject jim2 = new BasicDBObject("name", "jim2"); int count = mongoDb.deleteByDbs(jim2, collName); return count; } public int updateTest(String collName) { DBObject liuting = new BasicDBObject(); DBObject liuting2 = new BasicDBObject(); liuting2.put("$set", new BasicDBObject("gender", "female")); int count = mongoDb.update(liuting, liuting2, false, true, collName); return count; } public List<String> findWithPageTest(String collName) { DBCursor cursor = mongoDb.findWithPage(null, null, 0, 3, collName); return convertCursorToList(cursor); } public List<String> findWithConditionTest(String collName) { DBObject where = new BasicDBObject(); where.put("age", new BasicDBObject("$lte", 26)); where.put("gender", "female"); DBCursor cursor = mongoDb.findNoPage(where, null,collName); return convertCursorToList(cursor); } public List<String> findNoPageTest(String collName) { DBObject keys = new BasicDBObject(); keys.put("_id", false); keys.put("name", true); keys.put("age", true); DBCursor cursor = mongoDb.findNoPage(null, keys, collName); return convertCursorToList(cursor); } private List<String> convertCursorToList(DBCursor cursor) { List<String> results = new ArrayList<String>(); while(cursor.hasNext()) { DBObject dbObject = cursor.next(); for(String key : dbObject.keySet()) { results.add("{"+key+":"+dbObject.get(key)+"}"); } } return results; }}
TestActivity.java
package com.hills.happytest;import java.util.List;import android.app.Activity;import android.app.AlertDialog;import android.content.DialogInterface;import android.os.AsyncTask;import android.os.Bundle;import android.view.View;import android.view.View.OnClickListener;import android.widget.Button;import com.hills.happytest.utils.MongoDBDao;import com.hills.happytest.utils.MongoDBUtil;public class TestActivity extends Activity implements OnClickListener{ private Button mongoTestBtn1; private Button mongoTestBtn2; private Button mongoTestBtn3; private Button mongoTestBtn4; private Button mongoTestBtn5; private Button mongoTestBtn6; private Button mongoTestBtn7; private Button mongoTestBtn8; // The Object use to MongoDB Operate. private MongoDBDao mongoDbDao; // The Collection Name in MongoDB. private String collName = "androidDB"; private final int CREATE_COLLECTION_TEST = 100; private final int INSERT_TEST = 101; private final int INSERT_BATCH_TEST = 102; private final int DELETE_BY_ID_TEST = 103; private final int DELETE_BY_DBS_TEST = 104; private final int UPDATE_TEST = 105; private final int FIND_WITH_PAGE_TEST = 106; private final int FIND_NOPAGE_TEST = 107; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.mongodb_test); findViewAndSetListener(); mongoDbDao = new MongoDBDao(); } private void findViewAndSetListener() { mongoTestBtn1 = (Button) findViewById(R.id.mongodb_btn1); mongoTestBtn2 = (Button) findViewById(R.id.mongodb_btn2); mongoTestBtn3 = (Button) findViewById(R.id.mongodb_btn3); mongoTestBtn4 = (Button) findViewById(R.id.mongodb_btn4); mongoTestBtn5 = (Button) findViewById(R.id.mongodb_btn5); mongoTestBtn6 = (Button) findViewById(R.id.mongodb_btn6); mongoTestBtn7 = (Button) findViewById(R.id.mongodb_btn7); mongoTestBtn8 = (Button) findViewById(R.id.mongodb_btn8); mongoTestBtn1.setOnClickListener(this); mongoTestBtn2.setOnClickListener(this); mongoTestBtn3.setOnClickListener(this); mongoTestBtn4.setOnClickListener(this); mongoTestBtn5.setOnClickListener(this); mongoTestBtn6.setOnClickListener(this); mongoTestBtn7.setOnClickListener(this); mongoTestBtn8.setOnClickListener(this); } @Override public void onClick(View v) { MyAsyncTast myAsyncTast = new MyAsyncTast(); switch(v.getId()){ case R.id.mongodb_btn1: myAsyncTast.execute(CREATE_COLLECTION_TEST); break; case R.id.mongodb_btn2: myAsyncTast.execute(INSERT_TEST); break; case R.id.mongodb_btn3: myAsyncTast.execute(INSERT_BATCH_TEST); break; case R.id.mongodb_btn4: myAsyncTast.execute(DELETE_BY_ID_TEST); break; case R.id.mongodb_btn5: myAsyncTast.execute(DELETE_BY_DBS_TEST); break; case R.id.mongodb_btn6: myAsyncTast.execute(UPDATE_TEST); break; case R.id.mongodb_btn7: myAsyncTast.execute(FIND_WITH_PAGE_TEST); break; case R.id.mongodb_btn8: myAsyncTast.execute(FIND_NOPAGE_TEST); break; } } class MyAsyncTast extends AsyncTask<Object, Object, Object>{ @Override protected Object doInBackground(Object... params) { Object result = null; switch(Integer.parseInt(params[0].toString())) { case CREATE_COLLECTION_TEST: mongoDbDao.createCollectionTest(collName); break; case INSERT_TEST: mongoDbDao.insertTest(collName); break; case INSERT_BATCH_TEST: mongoDbDao.insertBatchTest(collName); break; case DELETE_BY_ID_TEST: result = mongoDbDao.deleteByIdTest(collName); break; case DELETE_BY_DBS_TEST: result = mongoDbDao.deleteByDbsTest(collName); break; case UPDATE_TEST: result = mongoDbDao.updateTest(collName); break; case FIND_WITH_PAGE_TEST: result = mongoDbDao.findWithPageTest(collName); break; case FIND_NOPAGE_TEST: result = mongoDbDao.findNoPageTest(collName); break; } return result; } @SuppressWarnings("unchecked") @Override protected void onPostExecute(Object result) { if(result instanceof Integer) { showDialogWithText("操作结果码:"+result.toString()); }else if(result instanceof List) { String resText = ""; for(String res : ((List<String>) result)) { resText += res + "\n"; } showDialogWithText("操作结果\n:"+resText); } super.onPostExecute(result); } } private void showDialogWithText(String text) { AlertDialog.Builder builder = new AlertDialog.Builder(this); builder.setIcon(R.drawable.ic_launcher); builder.setTitle("MongoDB操作结果"); builder.setMessage(text); builder.setNeutralButton("确定", new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { dialog.dismiss(); } }); builder.create().show(); } @Override protected void onDestroy() { // Close MongoDB Connection If It is Not Null. if(MongoDBUtil.getConnection() != null) { MongoDBUtil.getConnection().close(); } super.onDestroy(); }}
添加权限
<uses-permission Android:name="android.permission.INTERNET"/>
关于怎么在Android中连接MongoDB数据库问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注编程网行业资讯频道了解更多相关知识。