使用MyEclipse對MongoDB數據庫進行增刪改查操作

使用MyEclipse對MongoDB數據庫進行增刪改查操作

使用MyEclipse對MongoDB數據庫進行增刪改查操作

1.導入JAR包

使用了Spring3.0；此類包，可以上網查詢“MongoDB相關JAR包”

2.創建一個Person實體類

源代碼如下：

public class Person(){
//屬性
Private String id;	 //id
Private String name;	 //name
Private int age;	 //age
//構造方法
public Person(){
}
public Person(String name,int age){
this.name = name;
this.age  = age;
}
public Person(String id,String name,int age){
this.id	  = id;
this.name = name;
this.age  = age;
}
public String toString(){
return “Person[ id = ”+id+“name=”+name+“age=”+age +”]”;
}
/**以下為屬性的get/set方法**/
.................................
}
 
/**以上代碼中一共有三個構造方法，用於傳遞參數數據**/ 
 

3.創建一個方法接口

1. 創建一個名為AbstractRepository 的接口，源代碼如下：

public interface AbstractRepository(){
//增加方法
public void insert(Person person);
//按ID查詢對象
public Person findOne(String id);
//查詢所有
public List findAll();
//按ID刪除
public void removeOne(String id);
//刪除所有
public void removeAll();
//查詢並修改
public void findAndModfy(String id);
}
 

4.接口方法實現類

1.創建一個名為PersonRepository的類並現實AbstractRepository 接口

源代碼如下：

public class PersonRepository implements AbstractRepository{
 
Private MongoTemplate mongoTemplate;
 
/**mongoTemplate的get/set方法**/
public MongoTemplate getMongoTemplate(){
return mongoTemplate;
} 
 
public void setMongoTemplate(MongoTemplate mongoTemplate) {
this.mongoTemplate = mongoTemplate;
}
 
//查詢所有
public List findAll(){
return getMongoTemplate().find(new Query, Person.class);
}
 
 
 
//查詢修改
public void findAndModify(){
getMongoTemplate().updateFirst(new Query(Criteria.where(“id”)).is(id) ,
new Update().inc(“age” , 3));
}
 
 
 
 
//按條件查詢
public List findAll(){
Pattern pattern = Pattern.compile(regex,Pattern.CASE_INSENSITIVE);
Criteria criteria = new Criteria(“name”).regex(pattern.toString());
return getMongoTemplate().find(new Query(criteria), Person.class)
}
 
 
 
 
//按ID查詢對象
public Person findOne(String id){
return getMongoTemplate().findOne(new 
Query(Criteria.where(“id”).is(id), Person.class));
}
 
 
 
//增加
public void insert(Person person){
getMongoTemplate().insert(person);
}
 
 
 
 
//刪除所有
public void removeAll(){
Listlist = this.finAll();
If(list != null){
for(Person person:list){
getMongoTemplate().remove(person)
 
}
}
}
 
 
 
//按ID刪除
public void removeOne(String id){
Criteria criteria = Criteria.where(“id”).in(id);
if(criteria != null){
Query query = new Query(criteria);
if(query != null && getMongoTemplate().findOne(query,Person.class)){
getMongoTemplate().remoev(getMongoTemplate().findOne(query,
Person.class));
}
}
}
}

5.配置ApplicationContext.xml

我們使用了Spring，自然要配置ApplicationContext；因為各版本不同，所以ApplicationContext.xml中的系統默認頭代碼請復制我以下的來使用，要不然會代碼錯誤：

ApplicationContext.xml代碼如圖，雖然左上角出現紅X的錯誤提示。提示的

信息大概是有重復的注釋。不用去管他，只要代碼裡面沒有紅線就好。

6.寫測試類進行測試

創建一個有mian方法的測試類Test：部分方法的源代碼如下：

public class Test{
 
private static log log = logFactory.getlog(Test.class.getName());
 
private AbstractRepository pr = null;
 
//初始方法
public void init(){
log.debug(“開始啟動”);
ApplicationContext ac = new ClassPathXmlApplicationContext(
“applicationContext.xml”);
pr = (PersonRepository) ac.getbean(“personRepository”);
}
 
//添加方法
public void insert(){
Person p = new Person(“id1”,“cuiran”,27);
pr.insert(p);
log.debug(“添加成功！”);
}
 
 
//按ID查詢對象
public void finOne(){
String id = “id1”;
Person p =  pr.findOne(id);
log.debug(p);
}
}
 
 
//查詢所有
public void findAll(){
List list = pr.findAll();
log.debug(“查詢結果：”);
for(Person p:list){
log.debug(p.toString);
}
}
 
//測試方法
public void start(){
init();	 //執行初始化
insert();	 //執行添加方法
}
 
 
//mian方法
public static void main(String args []){
Text text = new Text();
 test.start();
}