Android编程连接MongoDB及增删改查等基本操作示例

2024-02-06 00:10:03 74

本文实例讲述了Android编程连接MongoDB及增删改查等基本操作。分享给大家供大家参考，具体如下：

MongoDB简介

Mongodb，分布式文档存储数据库，由C++语言编写，旨在为WEB应用提供可扩展的高性能数据存储解决方案。MongoDB是一个高性能，开源，无模式的文档型数据库,是当前NoSql数据库中比较热门的一种。它在许多场景下可用于替代传统的关系型数据库或键/值存储方式。Mongo使用C++开发。

Mongo安装参考

1）下载安装包文件，解压到某一文件夹下。
官方下载地址：http://www.mongodb.org/downloads
2）配置环境变量：在path后添加安装路径。
3）启动Mongo数据库：
进入“cmd”->键入“mongod--dbpathD:\amp\MongoDBDATA”
D:\amp\MongoDBDATA表示数据库文件存储路径
4）启动Mongo客户端：
mongo127.0.0.1:27017/admin

Android连接MongoDB

步骤1：下载并导入jar包到工程
步骤2：安装MongoDB到PC端（参见MongoDB安装）
步骤3：编写代码连接MongoDB实现简单操作（增删改查）

代码参考（Android端，也适用于java等工程）

1. MongoDBUtil.java

packagecom.hills.happytest.utils;
importjava.util.List;
importorg.bson.types.ObjectId;
importcom.mongodb.BasicDBObject;
importcom.mongodb.DB;
importcom.mongodb.DBCollection;
importcom.mongodb.DBCursor;
importcom.mongodb.DBObject;
importcom.mongodb.Mongo;
/**
*ClassName:MongoDBUtil.java
*Function:
*TheUtilthatMongoDBOperate.
*Modifications:
*
*@authorGymYung.
*@DateTime2014-10-29下午1:56:49
*@version1.0
*/
publicclassMongoDBUtil{
staticMongoconnection=null;
staticDBdb=null;
publicMongoDBUtil(StringdbName)throwsException
{
connection=newMongo("10.0.2.2:27017");
db=connection.getDB(dbName);
}
publicstaticMongogetConnection(){
returnconnection;
}
/**
*Createablanketcollection.
*@paramcollName:collectionname.
*/
publicvoidcreateCollection(StringcollName)
{
DBObjectdbs=newBasicDBObject();
dbs.put("test","test");
db.createCollection(collName,dbs);
}
/**
*InsertdbObjectintocollection.
*@paramdbObject
*@paramcollName
*/
publicvoidinsert(DBObjectdbObject,StringcollName)
{
DBCollectioncollection=db.getCollection(collName);
collection.insert(dbObject);
}
/**
*InsertdbObjectlistintocollection.
*@paramdbObjects
*@paramcollName
*/
publicvoidinsertBatch(ListdbObjects,StringcollName)
{
DBCollectioncollection=db.getCollection(collName);
collection.insert(dbObjects);
}
/**
*DeletedataById.
*@paramid
*@paramcollName
*@return
*/
publicintdeleteById(Stringid,StringcollName)
{
DBCollectioncollection=db.getCollection(collName);
DBObjectdbs=newBasicDBObject("_id",newObjectId(id));
intcounts=collection.remove(dbs).getN();
returncounts;
}
/**
*DeletedataByCondition.
*@paramdbObject
*@paramcollName
*@return
*/
publicintdeleteByDbs(DBObjectdbObject,StringcollName)
{
DBCollectioncollection=db.getCollection(collName);
intcount=collection.remove(dbObject).getN();
returncount;
}
/**
*UpdateData.
*@paramfind
*@paramupdate
*@paramupsert
*@parammulti
*@paramcollName
*@return
*/
publicintupdate(DBObjectfind,DBObjectupdate,booleanupsert,booleanmulti,StringcollName)
{
DBCollectioncollection=db.getCollection(collName);
intcount=collection.update(find,update,upsert,multi).getN();
returncount;
}
/**
*FindDataWithPage.
*@paramref
*@paramkeys
*@paramstart
*@paramlimit
*@paramcollName
*@return
*/
publicDBCursorfindWithPage(DBObjectwhere,DBObjectselection,intstart,intlimit,StringcollName)
{
DBCursorcursor=findNoPage(where,selection,collName);
returncursor.limit(limit).skip(start);
}
/**
*FindDataNoPage.
*@paramref
*@paramkeys
*@paramcollName
*@return
*/
publicDBCursorfindNoPage(DBObjectwhere,DBObjectselection,StringcollName)
{
DBCollectioncollection=db.getCollection(collName);
DBCursorcursor=collection.find(where,selection);
returncursor;
}
}

2.MongoDBDao.java

packagecom.hills.happytest.utils;
importjava.util.ArrayList;
importjava.util.List;
importcom.mongodb.BasicDBObject;
importcom.mongodb.DBCursor;
importcom.mongodb.DBObject;
/**
*ClassName:MongoDBDao.java
*Function:
*TheDataDaothatMongoDBOperate.
*Modifications:
*
*@authorAdministrator
*@DateTime2014-10-29下午1:57:58
*@version1.0
*/
publicclassMongoDBDao{
privatestaticMongoDBUtilmongoDb;
//Init.MongoDBUtil.
static{
try{
mongoDb=newMongoDBUtil("test");
}catch(Exceptione){
e.printStackTrace();
}
}
/**
*TestCreateablanketcollection.
*@paramcollName:collectionname.
*/
publicvoidcreateCollectionTest(StringcollName)
{
mongoDb.createCollection(collName);
}
/**
*TestInsertdbObjectintocollection.
*@paramcollNameCollectionName.
*/
publicvoidinsertTest(StringcollName)
{
DBObjectdbs=newBasicDBObject();
dbs.put("name","gymyung");
dbs.put("age",20);
Listbooks=newArrayList();
books.add("EXTJS");
books.add("MONGDB");
books.add("JAVA");
dbs.put("books",books);
mongoDb.insert(dbs,collName);
}
/**
*TestInsertdbObjectlistintocollection.
*@paramcollNameCollectionName.
*/
publicvoidinsertBatchTest(StringcollName)
{
ListdbObjects=newArrayList();
DBObjectjim2=newBasicDBObject("name","jim2");
DBObjectliuting=newBasicDBObject();
liuting.put("name","liuting");
liuting.put("age","22");
dbObjects.add(jim2);
dbObjects.add(liuting);
mongoDb.insertBatch(dbObjects,collName);
}
/**
*TestDeletedataById.
*@paramcollNameCollectionName.
*@returnOperateResultCode.
*/
publicintdeleteByIdTest(StringcollName)
{
intcounts=mongoDb.deleteById("54507d19cbbd7a385c129ef5",collName);
returncounts;
}
/**
*TestDeletedataByCondition.
*@paramcollNameCollectionName.
*@returnOperateResultCode.
*/
publicintdeleteByDbsTest(StringcollName)
{
DBObjectjim2=newBasicDBObject("name","jim2");
intcount=mongoDb.deleteByDbs(jim2,collName);
returncount;
}
/**
*TestUpdateData.
*@paramcollNameCollectionName.
*@returnOperateResultCode.
*/
publicintupdateTest(StringcollName)
{
DBObjectliuting=newBasicDBObject();
DBObjectliuting2=newBasicDBObject();
liuting2.put("$set",newBasicDBObject("gender","female"));
intcount=mongoDb.update(liuting,liuting2,false,true,collName);
returncount;
}
/**
*TestFindDataWithPage.
*@paramcollNameCollectionName.
*@returnStringListResult.
*/
publicListfindWithPageTest(StringcollName)
{
DBCursorcursor=mongoDb.findWithPage(null,null,0,3,collName);
returnconvertCursorToList(cursor);
}
/**
*TestFindDataWithCondition.
*@paramcollNameCollectionName.
*@returnStringListResult.
*/
publicListfindWithConditionTest(StringcollName)
{
DBObjectwhere=newBasicDBObject();
where.put("age",newBasicDBObject("$lte",26));
where.put("gender","female");
DBCursorcursor=mongoDb.findNoPage(where,null,collName);
returnconvertCursorToList(cursor);
}
/**
*TestFindDataNoPage.
*@paramcollNameCollectionName.
*@returnStringListResult.
*/
publicListfindNoPageTest(StringcollName)
{
DBObjectkeys=newBasicDBObject();
keys.put("_id",false);
keys.put("name",true);
keys.put("age",true);
DBCursorcursor=mongoDb.findNoPage(null,keys,collName);
returnconvertCursorToList(cursor);
}
/**
*ConvertCursorToList.
*@paramcursorRequiredDBCursor.
*@returnStringListResult.
*/
privateListconvertCursorToList(DBCursorcursor)
{
Listresults=newArrayList();
while(cursor.hasNext())
{
DBObjectdbObject=cursor.next();
for(Stringkey:dbObject.keySet())
{
results.add("{"+key+":"+dbObject.get(key)+"}");
}
}
returnresults;
}
}

3.TestActivity.java

packagecom.hills.happytest;
importjava.util.List;
importandroid.app.Activity;
importandroid.app.AlertDialog;
importandroid.content.DialogInterface;
importandroid.os.AsyncTask;
importandroid.os.Bundle;
importandroid.view.View;
importandroid.view.View.OnClickListener;
importandroid.widget.Button;
importcom.hills.happytest.utils.MongoDBDao;
importcom.hills.happytest.utils.MongoDBUtil;
/**
*ClassName:TestActivity.java
*Function:
*TestMongoDBOperateonAndroiddevice.
*Modifications:
*
*@authorGymYung.
*@DateTime2014-10-29下午1:53:40
*@version1.0
*/
publicclassTestActivityextendsActivityimplementsOnClickListener{
/**************ComponentinLayout.***************/
privateButtonmongoTestBtn1;
privateButtonmongoTestBtn2;
privateButtonmongoTestBtn3;
privateButtonmongoTestBtn4;
privateButtonmongoTestBtn5;
privateButtonmongoTestBtn6;
privateButtonmongoTestBtn7;
privateButtonmongoTestBtn8;
//TheObjectusetoMongoDBOperate.
privateMongoDBDaomongoDbDao;
//TheCollectionNameinMongoDB.
privateStringcollName="androidDB";
/**************OperateCode********************/
privatefinalintCREATE_COLLECTION_TEST=100;
privatefinalintINSERT_TEST=101;
privatefinalintINSERT_BATCH_TEST=102;
privatefinalintDELETE_BY_ID_TEST=103;
privatefinalintDELETE_BY_DBS_TEST=104;
privatefinalintUPDATE_TEST=105;
privatefinalintFIND_WITH_PAGE_TEST=106;
privatefinalintFIND_NOPAGE_TEST=107;
@Override
protectedvoidonCreate(BundlesavedInstanceState){
super.onCreate(savedInstanceState);
setContentView(R.layout.mongodb_test);
findViewAndSetListener();
mongoDbDao=newMongoDBDao();
}
/**
*Function:
*FindViewAndSetListener.
*@authorAdministrator
*@DateTime2014-10-29下午1:08:50
*/
privatevoidfindViewAndSetListener(){
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
publicvoidonClick(Viewv){
MyAsyncTastmyAsyncTast=newMyAsyncTast();
switch(v.getId()){
caseR.id.mongodb_btn1:
myAsyncTast.execute(CREATE_COLLECTION_TEST);
break;
caseR.id.mongodb_btn2:
myAsyncTast.execute(INSERT_TEST);
break;
caseR.id.mongodb_btn3:
myAsyncTast.execute(INSERT_BATCH_TEST);
break;
caseR.id.mongodb_btn4:
myAsyncTast.execute(DELETE_BY_ID_TEST);
break;
caseR.id.mongodb_btn5:
myAsyncTast.execute(DELETE_BY_DBS_TEST);
break;
caseR.id.mongodb_btn6:
myAsyncTast.execute(UPDATE_TEST);
break;
caseR.id.mongodb_btn7:
myAsyncTast.execute(FIND_WITH_PAGE_TEST);
break;
caseR.id.mongodb_btn8:
myAsyncTast.execute(FIND_NOPAGE_TEST);
break;
}
}
/**
*ClassName:TestActivity.java
*Function:
*ExecuteInternetTaskbyAsync...
*Modifications:
*
*@authorAdministrator
*@DateTime2014-10-29下午1:54:34
*@version1.0
*/
classMyAsyncTastextendsAsyncTask{
@Override
protectedObjectdoInBackground(Object...params){
Objectresult=null;
switch(Integer.parseInt(params[0].toString()))
{
caseCREATE_COLLECTION_TEST:
mongoDbDao.createCollectionTest(collName);
break;
caseINSERT_TEST:
mongoDbDao.insertTest(collName);
break;
caseINSERT_BATCH_TEST:
mongoDbDao.insertBatchTest(collName);
break;
caseDELETE_BY_ID_TEST:
result=mongoDbDao.deleteByIdTest(collName);
break;
caseDELETE_BY_DBS_TEST:
result=mongoDbDao.deleteByDbsTest(collName);
break;
caseUPDATE_TEST:
result=mongoDbDao.updateTest(collName);
break;
caseFIND_WITH_PAGE_TEST:
result=mongoDbDao.findWithPageTest(collName);
break;
caseFIND_NOPAGE_TEST:
result=mongoDbDao.findNoPageTest(collName);
break;
}
returnresult;
}
@SuppressWarnings("unchecked")
@Override
protectedvoidonPostExecute(Objectresult){
if(resultinstanceofInteger)
{
showDialogWithText("操作结果码："+result.toString());
}elseif(resultinstanceofList)
{
StringresText="";
for(Stringres:((List)result))
{
resText+=res+"\n";
}
showDialogWithText("操作结果\n："+resText);
}
super.onPostExecute(result);
}
}
/**
*Function:
*ShowDialogWithText.
*@authorAdministrator
*@DateTime2014-10-29下午1:21:34
*@paramtext
*/
privatevoidshowDialogWithText(Stringtext)
{
AlertDialog.Builderbuilder=newAlertDialog.Builder(this);
builder.setIcon(R.drawable.ic_launcher);
builder.setTitle("MongoDB操作结果");
builder.setMessage(text);
builder.setNeutralButton("确定",newDialogInterface.OnClickListener()
{
@Override
publicvoidonClick(DialogInterfacedialog,intwhich)
{
dialog.dismiss();
}
});
builder.create().show();
}
@Override
protectedvoidonDestroy(){
//CloseMongoDBConnectionIfItisNotNull.
if(MongoDBUtil.getConnection()!=null)
{
MongoDBUtil.getConnection().close();
}
super.onDestroy();
}
}

4. 添加权限

更多关于Android相关内容感兴趣的读者可查看本站专题：《Android数据库操作技巧总结》、《Android编程之activity操作技巧总结》、《Android开发入门与进阶教程》、《Android资源操作技巧汇总》、《Android视图View技巧总结》及《Android控件用法总结》

希望本文所述对大家Android程序设计有所帮助。

Android编程连接MongoDB及增删改查等基本操作示例

热门推荐

随机推荐