MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
// more infomation please access https://docs.mongodb.com/getting-started/csharp/
namespace MongoDBTest
{
public static class MongoDBHelper
{
private static MongoServerAddress server =
new MongoServerAddress(
"127.0.0.1",
27017);
private static MongoClientSettings setting =
new MongoClientSettings();
private static MongoCredential credential = MongoCredential.CreateCredential(
"databaseName",
"username",
"password");
private static void ConfigureSettings(MongoClientSettings setting)
{
// setting.Credentials = (IEnumerable<MongoCredential>)credential;
setting.ConnectTimeout = TimeSpan.FromSeconds(
20);
setting.ConnectionMode =
ConnectionMode.Direct;
setting.GuidRepresentation =
GuidRepresentation.CSharpLegacy;
setting.IPv6 =
false;
setting.MaxConnectionIdleTime = TimeSpan.FromMinutes(
10);
setting.MaxConnectionLifeTime = TimeSpan.FromMinutes(
30);
setting.MaxConnectionPoolSize =
50;
setting.SocketTimeout = TimeSpan.FromSeconds(
30);
setting.WaitQueueSize =
250;
setting.WaitQueueTimeout = TimeSpan.FromMilliseconds(
500);
}
/// <summary>
/// use filter to find data from database
/// </summary>
/// <typeparam name="TClass">mapping class,according Builder<TClass></typeparam>
/// <param name="databaseName">database name</param>
/// <param name="collectionName">collection name</param>
/// <param name="filter">FilterDefinition,the field of Builders</param>
/// <param name="sort">SortDefinition,the field of Builders</param>
/// <returns>List<TClass>,get by ToList() for changing find result</returns>
public static List<TClass> FindData<TClass>(
string databaseName,
string collectionName,FilterDefinition<TClass> filter, SortDefinition<TClass> sort=
null)
{
try
{
ConfigureSettings(setting);
var client =
new MongoClient(setting);
var database =
client.GetDatabase(databaseName);
var collection = database.GetCollection<TClass>
(collectionName);
var result =
collection.Find(filter).Sort(sort);
var test =
result.ToList();
return test;
}catch(Exception e)
{
throw e;
}
}
public static int InserOne<TClass>(
string databaseName,
string collectionName,TClass tClass)
{
try {
ConfigureSettings(setting);
var client =
new MongoClient(setting);
var database =
client.GetDatabase(databaseName);
var collection = database.GetCollection<TClass>
(collectionName);
collection.InsertOne(tClass);
return 1;
}
catch(Exception e)
{
throw e;
}
}
public static int UpdateMany<TClass>(
string databaseName,
string collectionName, FilterDefinition<TClass> filter, UpdateDefinition<TClass>
update)
{
try
{
ConfigureSettings(setting);
var client =
new MongoClient(setting);
var database =
client.GetDatabase(databaseName);
var collection = database.GetCollection<TClass>
(collectionName);
collection.UpdateMany(filter, update);
return 1;
}
catch (Exception e)
{
throw e;
}
}
public static int UpdateOne<TClass>(
string databaseName,
string collectionName, FilterDefinition<TClass> filter, UpdateDefinition<TClass>
update)
{
try
{
ConfigureSettings(setting);
var client =
new MongoClient(setting);
var database =
client.GetDatabase(databaseName);
var collection = database.GetCollection<TClass>
(collectionName);
collection.UpdateOne(filter, update);
return 1;
}
catch (Exception e)
{
throw e;
}
}
public static int DeleteOne<TClass>(
string databaseName,
string collectionName, FilterDefinition<TClass>
filter)
{
try
{
ConfigureSettings(setting);
var client =
new MongoClient(setting);
var database =
client.GetDatabase(databaseName);
var collection = database.GetCollection<TClass>
(collectionName);
collection.DeleteOne(filter);
return 1;
}
catch (Exception e)
{
throw e;
}
}
public static int DeleteMany<TClass>(
string databaseName,
string collectionName, FilterDefinition<TClass>
filter)
{
try
{
ConfigureSettings(setting);
var client =
new MongoClient(setting);
var database =
client.GetDatabase(databaseName);
var collection = database.GetCollection<TClass>
(collectionName);
collection.DeleteMany(filter);
return 1;
}
catch (Exception e)
{
throw e;
}
}
}
}
MongodbHelper
标签：text socket configure 基础 rto god getc tde timeout
