如何关闭mongodb groovy连接(soapUI)

Question

我有一个从mongodb (SoapUI)获取数据的groovy脚本。

@Grab(group='com.gmongo', module='gmongo', version='1.5')

import com.gmongo.GMongo
import com.mongodb.MongoCredential
import com.mongodb.*
import com.mongodb.ServerAddress
import com.gmongo.*
import com.mongodb.MongoURI
import com.mongodb.DBCursor;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBList
import org.bson.types.ObjectId

//define variables from mongo document
def mongo_name
def mongo_description
def mongo_type


//define mongo_variables and initiate mongo connection
def mongoendpoint = context.expand( '${#Project#mongoendpoint}' )
def mongocollection=context.expand( '${#Project#mongocollection_products}' )
def mongo= new GMongo (new MongoURI(mongoendpoint))
def db = mongo.getDB(mongocollection)
def collection = db.getCollection("ProductItems")

//define elements from API response
def api_productId = context.expand('${#Project#package_parent}')

//get document from mongo
DBCursor cursor=collection.find(_id : api_productId)
//log.info cursor

if (cursor.hasNext() )
{ DBObject obj = cursor.next()
//mongo_name=obj.name.toString()
}

 //close cursor
cursor.close()

我的问题是，在我关闭ReadyAPI之前，连接一直保持打开状态，这会导致太多打开(而不是关闭)的连接。

是否一定要显式关闭连接？(已搜索，但找不到可行的解决方案)

Answer 1

您需要使用mongo客户端，以便能够关闭连接。使用mongo客户端，而不是GMongo。因此，您可以尝试如下所示：

@Grab(group='com.gmongo', module='gmongo', version='1.5')

import com.gmongo.GMongo
import com.mongodb.MongoCredential
import com.mongodb.*
import com.mongodb.ServerAddress
import com.gmongo.*
import com.mongodb.MongoURI
import com.mongodb.DBCursor;
import com.mongodb.BasicDBObject;
import com.mongodb.BasicDBList
import org.bson.types.ObjectId

//define variables from mongo document
def mongo_name
def mongo_description
def mongo_type


//define mongo_variables and initiate mongo connection
def mongoendpoint = context.expand( '${#Project#mongoendpoint}' )
def mongocollection=context.expand( '${#Project#mongocollection_products}' )
mongoClient = new MongoClient( mongoendpoint ) 
def db = mongo.getDB(mongocollection)
def collection = db.getCollection("ProductItems")

//define elements from API response
def api_productId = context.expand('${#Project#package_parent}')

//get document from mongo
DBCursor cursor=collection.find(_id : api_productId)
//log.info cursor

if (cursor.hasNext() )
{ DBObject obj = cursor.next()
//mongo_name=obj.name.toString()
}

 //close cursor
cursor.close()

//close connection 
mongoClient.close()