FusionWiz의 스토리

// on the connection string

var connectionString = "mongodb://user:pwd@localhost/?safe=true";

var server = MongoServer.Create(connectionString);

// in code

var settings = new MongoServerSettings() {

   DefaultCredentials = new MongoCredentials("user", "pwd"),

   SafeMode = SafeMode.True

};

var server = MongoServer.Create(settings);

var credentialsStore = new MongoCredentialsStore();

credentialsStore.AddCredentials(

      "hr", new MongoCredentials("user1", "pwd1"));

credentialsStore.AddCredentials(

      "inventory", new MongoCredentials("user2", "pwd2"));

var settings = new MongoServerSettings {

      CredentialsStore = credentialsStore,

      SafeMode = SafeMode.True

};

var server = MongoServer.Create(settings);

var credentials = new MongoCredentials("user", "pwd");

var database = server.GetDatabase("hr", credentials);

var cs = "mongodb://user(admin):pwd@localhost/?safe=true";

var server = MongoServer.Create(cs);

var adminCredentials = new MongoCredentials("user", "pwd", true);

var settings = new MongoServerSettings {

      DefaultCredentials = adminCredentials,

      SafeMode = SafeMode.True

};

var server = MongoServer.Create(settings);

// http://www.csharpstudy.com/Tips/Tips-mongodb.aspx

// Mongo DB를 위한 Connection String

string connString = "mongodb://localhost";

// MongoClient 클라이언트 객체 생성

MongoClient cli = new MongoClient(connString);

// testdb 라는 데이타베이스 가져오기

// 만약 해당 DB 없으면 Collection 생성시 새로 생성함

MongoDatabase testdb = cli.GetServer().GetDatabase("testdb");

// testdb 안에 Customers 라는 컬렉션(일종의 테이블)

// 가져오기. 만약 없으면 새로 생성.

var customers = testdb.GetCollection<Customer>("Customers");

// INSERT - 컬렉션 객체의 Insert() 메서드 호출

// Insert시 _id 라는 자동으로 ObjectID 생성

// 이 _id는 해당 다큐먼트는 나타는 키.

Customer cust1 = new Customer { Name = "Kim", Age = 30 };

customers.Insert(cust1);

ObjectId id = cust1.Id;

// SELECT - id로 검색

IMongoQuery query = Query.EQ("_id", id);

var result = customers.Find(query).SingleOrDefault();

if (result != null)

{

   Console.WriteLine(result.ToString());

}

// UPDATE

//    Save() = 전체 다큐먼트 갱신.

//    Update() = 부분 수정

cust1.Age = 31;

customers.Save(cust1);           

// DELETE

var qry = Query.EQ("_id", id);

customers.Remove(qry);

static Tuple<Int64, Int64> StoreUniqueNumber(int Count)

{

    MongoClient cli = new MongoClient(DB_ConnectString);

    MongoDatabase db = cli.GetServer().GetDatabase(BasicLogDatabaseName);

    var UniqueNumberCol = db.GetCollection<BsonDocument>("UniqueNumber");

    bool IsLoop = true;

    while (IsLoop)

    {

        var result = UniqueNumberCol.FindAll().SingleOrDefault();

        var firstNum = result["firts"].ToInt64();

        var lastNum = result["last"].ToInt64();

        var query = Query.And(

            Query.EQ("firts", firstNum),

            Query.EQ("last", lastNum)

        );

        var update = Update.Set("firts", lastNum + 1).Set("last", lastNum + Count);

        var newResult = UniqueNumberCol.FindAndModify(query, SortBy.Null, update, true);

        if (newResult.Ok)

        {

            var newFirstNum = result["firts"].ToInt64();

            var newLastNum = result["last"].ToInt64();

            return Tuple.Create(newFirstNum, newLastNum);

        }

    }

    return Tuple.Create((Int64)0, (Int64)0);

}

/*

{

    "_id" : ObjectId("5209d0507dbe2af068a42aec"),

    "ID" : "jacking75",

    "Uniq" : 5,

    "date" : ISODate("2013-08-12T06:21:04Z")

}

*/

DateTime datetime = MongoDBLib.StringToDateTime(yyyyMMddHHmm);

// 로그인한 총 수를 얻는다

var collection = dbLib.BasicLogDB.GetCollection<BsonDocument>("LoginUser");

var query = Query.And(Query.GTE("date", datetime), Query.LTE("date", datetime.AddDays(1)));

// ID 필드 값 중 중복된 것을 제외하고 개수를 구한다

var UniqueLoginUserCount = collection.Distinct("ID", query).Count();

[BsonIgnoreExtraElements]

public class AddressEntry

{

  [BsonId]

  public BsonObjectId _id { get; set;}

  public string Name { get; set; }

  public DateTime Birthday { get; set; }

  public List<Email> EmailAddrs { get; set; }

  [BsonIgnore]

   public string Detail { get; set; }  // 맵핑하지 않는다

}

[BsonIgnoreExtraElements]

public class Email

{

  public string DisplayName { get; set; }

  public string MailAddress { get; set; }

}

// MongoDB에 접속

MongoClient cli = new MongoClient();

// Database를 선택

MongoDatabase db = cli.GetServer().GetDatabase("TestDB");

// 컬렉션 취득

MongoCollection<AddressEntry> col = db.GetCollection<AddressEntry>("AddressBook");

public void Order_Where_Member_1()

{

    var orderCollection = GetCollection(); // 컬렉션 취득을 함수화

    var orders = orderCollection.AsQueryable().Where( x => x.MemberId == 1 ).ToList();

    orders.ForEach( x =>

            {

                WriteOrder( x );

                x.OrderDetails.ToList().ForEach( y => WriteOrderDetail( y ) );

            }

        );

}

var query = from e in collection.AsQueryable<Employee>()

      where

         e.EmployeeStatus == Status.Active &&

         e.Salary > 100000

      select e;

// translates to:

{ EmployeeStatus : 1, Salary : { $gt : 100000 } }

var query = from e in collection.AsQueryable<Employee>()

      where e.Name.Contains("oh")

      select e;

// translates to:

{ nm: /oh/s }

var query = from e in collection.AsQueryable<Employee>()

      where e.Name.StartsWith("John")

      select e;

// translates to:

{ nm: /^John/s }

var query = from e in collection.AsQueryable<Employee>()

      where e.Name.Length == 4

      select e;

// translates to:

{ nm: /^.{4}$/s }

var query = from e in collection.AsQueryable<Employee>()

      where string.IsNullOrEmpty(e.Name)

      select e;

// translates to:

{ $or : [ { nm: { $type : 10 } }, { nm: "" } ] }

var query = from e in collection.AsQueryable<Employee>()

      where e.Name.ToLower() == "john macadam"

      select e;

// translates to:

{ nm: /^john macadam$/is }

var query = from e in collection.AsQueryable<Employee>()

      where e.Skills[0] == "Java"

      select e;

// translates to:

{ "Skills.0" : "Java" }

var query = from e in collection.AsQueryable<Employee>()

       where e.Skills.Length == 3

       select e;

// translates to:

{ Skills : { $size : 3 } }

var query = from e in collection.AsQueryable<Employee>()

      where e.Address.City == "Hoboken"

      select e;

// translates to:

{ "Address.City" : "Hoboken" }

var states = new [] { "NJ", "NY", "PA" };

var query = from e in collection.AsQueryable<Employee>()

      where states.Contains(e.Address.State)

      select e;

// translates to:

{ "Address.State" : { $in : [ "NJ", "NY", "PA" ] } }

// alternative syntax using C#/.NET driver "In" method

var query = from e in collection.AsQueryable<Employee>()

     where e.Address.State.In(states)

     select e;

var desiredSkills = new [] { "Java", "C#" };

var query = from e in collection.AsQueryable<Employee>()

      where e.Skills.ContainsAny(desiredSkills)

      select e;

// translates to:

{ "Skills" : { $in : [ "Java", "C#" ] } }

var query = from e in collection.AsQueryable<Employee>()

     where e.Skills.ContainsAll(desiredSkills)

     select e;

// translates to:

{ "Skills" : { $all : [ "Java", "C#" ] } }

// note: ContainsAny and ContainsAll are defined by the C#/.NET

driver and are not part of standard LINQ

var query = from e in collection.AsQueryable<Employee>()

   where

      e.Addresses.Any(a =>

         a.City == "Hoboken" &&

         a.State == "NJ")

   select e;

// translates to:

{ "Addresses" : { $elemMatch :

   { City : "Hoboken", State : "NJ" } } }

var query = from e in collection.AsQueryable()

      where

         e.Salary > 50000 &&

         Query.NotExists("EmployeeStatus").Inject()

      select e;

// translates to:

{

   Salary : { $gt : 50000 },

   EmployeeStatus : { $exists : false }

}