zoukankan      html  css  js  c++  java
  • mongo 监听指定语句

    class Program
        {
            private static string conn = "mongodb://47.104.206.56:27017";
            //数据库名称
            private static string dbName = "Test1";
            //集合名称
            private static string colName = "Demo4";
            //连接服务端
            static MongoClient client = new MongoClient(conn);
            //获取指定数据库
            static IMongoDatabase db = client.GetDatabase(dbName);
           static  MongoClientSettings settings = new MongoClientSettings();
            static async Task Main(string[] args)
            {
                int i = 0;
                MongoClientSettings settings = new MongoClientSettings();
                settings.ConnectionMode = ConnectionMode.Automatic;
                settings.ClusterConfigurator = cb =>
                {
                    //      监听执行语句
                    cb.Subscribe<CommandStartedEvent>(hand =>
                    {
                        Console.WriteLine($"命令名称:{hand.CommandName};命令内容{hand.Command}");
                    });
                };
                settings.Server = new MongoServerAddress("47.104.206.56", 27017);
                MongoClient client = new MongoClient(settings);
                //获取指定数据库
                IMongoDatabase db = client.GetDatabase(dbName);
                IMongoCollection<BsonDocument> coll = db.GetCollection<BsonDocument>(colName);
    
                while (true)
                {
                    var data = coll.Find(Builders<BsonDocument>.Filter.Empty).ToList();
                    Thread.Sleep(1000);
                }
            }
    
  • 相关阅读:
    将数据导入PostGIS
    图层管理
    CentIOS PHP 扩展库
    js 笔记 数组(对象)
    JSP 中的 Request 和 Response 对象
    ubuntu 安装 LAMP
    html 学习笔记
    Struts Ajax Json
    Servlet 笔记
    PHP+MYSQL 出现乱码的解决方法
  • 原文地址:https://www.cnblogs.com/yan7/p/9970934.html
Copyright © 2011-2022 走看看