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);
                }
            }
    
  • 相关阅读:
    Java线程的几种状态
    常用几种Java Web容器
    数据库触发器
    SQL优化及注意事项
    Oracle中rownum和rowid的区别
    数据库及SQL优化
    如何安装使用Impala
    Impala:新一代开源大数据分析引擎
    开源大数据查询分析引擎
    Google Dremel 原理
  • 原文地址:https://www.cnblogs.com/yan7/p/9970934.html
Copyright © 2011-2022 走看看