首页 > 数据库 >通用的CRUD之MongoDB

通用的CRUD之MongoDB

时间:2023-07-09 10:33:07浏览次数:46  
标签:10 通用 MongoDB CRUD id dictable testdb var DDATE

前言

这是一个简便的,对MongoDB增删改查,无需提前建库,建表,安装就能快速上手使用。
MongoDB多条件查询需要JSON的多层嵌套如{DDATE:{$gte:{$date:'2023-06-05T13:41'},$lte:{$date:'2023-06-05T23:59'}},Qty:{$gt:10}},书写时非常难受,还容易出错。
本类库支持类SQL查询语法,如"DDATE>='2023-06-05 09:12:24' and DDATE<='2023-06-05 13:28:48' and Qty>10",同时也支持原生查询语法。

安装

Install-Package DbCRUD.LiteDB 安装包

数据库连接及初始化 Database connection and initialization

 //数据库连接 Database connection
  IDbCRUD testdb =new MongoDbCRUD("mongodb://localhost:27017/testdb");
 //带连接选项初始化数据库连接对象
  MongoDbCRUD testdb = new MongoDbCRUD("mongodb://localhost:27017/testdb", opt => { opt.AutoCreateIndex = true;opt.AutoOpen = true; });

插入数据 Insert data

//*****插入对象数据 Insert object data synchronously
int id = testdb.Max<int>(tb_custormer);
var customer = new CrudTestModel
{
    ID = id + 1,
    Name = "objectData",
    Phones = new string[] { "80000", "90000" },
    FFloat=random.NextDouble(),
    IsActive = true,
    Dic = new Dictionary<string, object>
    {
        { "Name", "Embed_Data" },
        { "DDate", DateTime.Now }
    }
};
var result = testdb.Insert(tb_custormer, customer);
//*****插入字典数据 Insert dictionary data synchronously
var dic1 = new Dictionary<string, object>
{
    //{ "_id", 1 },//***如果不指定ID,插入时会自动编一个objectid的唯一ID
    { "Name", "MongodbCRUD" },
    { "Qty",random.Next(1,10000) },
    { "DDATE", DateTime.Now }
};
var dicresult = testdb.Insert(autoIDData, dic1);
//*****插入JSON数据 Insert JSON data 
string jsondata = JsonConvert.SerializeObject(dic1);
var result12 =testdb.Insert(tb_jsondata, jsondata);
//*****SQL语句插入 sql command insert 大小写敏感
var result13 = testdb.Insert($"insert into {sqldata}('name','date') values ('test1','{DateTime.Now.ToString("yyyy-MM-dd HH:mm:dd")}')");
//*****批量插入列表 Batch insert
List<Dictionary<string, object>> listdata = new List<Dictionary<string, object>>();
int maxid = testdb.Max<int>(dictable);
for (int i = 0; i < 10; i++)
{
    maxid++;
    var dic2 = new Dictionary<string, object>
    {
        { "_id",maxid },
        { "Name", "Batch insert" },
        { "Qty",random.Next(1,10000) },
        { "DDATE", DateTime.Now }
    };
    listdata.Add(dic2);
}
var listResult= testdb.Insert(dictable, listdata);

更新数据 update data

    var updata = new Dictionary<string, object>
    {
        { "Name", "更新指定字段数据 Updates the specified field data" },
        { "Qty", 600}
    };
    var upresult = testdb.UpDate(dictable, updata, "_id=6");   //更新_id=2的数据
    //【SQL语句更新】 更新_id=1的数据 ,mongodb对大小写敏感,所有sql语句中的表名和字段名大小写要与DB一致。
    var sql_up_result = testdb.UpDate("UPDATE dicdata SET Name='zzw',Qty=188 where _id=1");  

更新及插入数据(数据存在更新,不存在插入) Update and insert data (there is an update of the data, but there is no insertion)

    //***** 更新或插入数据 Update or insert data
    var dic1 = new Dictionary<string, object>
    {
        { "_id", 2 },
        { "Name", "Inserts or updates a single piece of data" },
        { "Qty", 200},
        { "DDATE", DateTime.Now }
    };
    var result= testdb.Upsert(dictable, dic1);

   //*****Batch insert or update Batch insert or update
    var dic3 = new Dictionary<string, object>
    {
        { "_id", 3 },
        { "Name", "Batch insert or update" },
        { "Qty", 300},
        { "DDATE", DateTime.Now }
    };
    List<Dictionary<string,object>> listdata=new List<Dictionary<string, object>> { dic3,dic1};
    var listresult = testdb.Upsert(dictable, listdata);

   //*****不存在就插入 Insert if it doesn't exist
    int maxid = testdb.Max<int>(dictable)+1;
    var dic4 = new Dictionary<string, object>
    {
        { "_id", maxid },
        { "Name", "根据_id不存在插入值" },
        { "Qty", 8000},
        { "DDATE", DateTime.Now }
    };
    testdb.Upsert(dictable, dic4);

查询数据 Query data

   ///查找id=2的数据
    var databyid = testdb.FindByID<Dictionary<string, object>>(dictable, 2);

    //查找id=2的数据,返回模型数据。 
    //【注意】模型和数据库中的列数不一致时,需要在模型上加 [BsonIgnoreExtraElements]特性,
    //        mongodb默认时UTC时间,如果要转本地时间,在模型时间属性上加[BsonDateTimeOptions(Kind =DateTimeKind.Local)]特性
    var modeldata = testdb.Find<CrudTestModel1>(tb_custormer, "_id=2")?.FirstOrDefault();

    ///查找id>2的数据,返回按DDATE排序,并排除dic列的最新一条数据
    var ondresult = testdb.FindOne<CrudTestModel>(tb_custormer, "_id>2", project: "!dic", sort: "!DDATE");

    //查找Qty>10的数据
    var wheredata = testdb.Find<Dictionary<string, object>>(dictable, "Qty>10");
    
    //【SQL语法,查找开头】,查找name中'Mongodbi'开头的数据,条件不区分大小写,字段名称区分大小写
    var like_result = testdb.FindAndResult<Dictionary<string, object>>(autoIDData, "Name like'Mongodb%'");

    //【SQL语法,查找结尾】,查找name中'crud'开头的数据,条件不区分大小写,字段名称区分大小写
    var like_result1 = testdb.FindAndResult<Dictionary<string, object>>(autoIDData, "Name like'%crud'");

    //【SQL语法,包含】,查找name中包含'odb'的数据,条件不区分大小写,字段名称区分大小写
    var like_result2 = testdb.FindAndResult<Dictionary<string, object>>(autoIDData, "Name like'%odb%'");
    
    //【MongoDB语法】,查找name中'Mongodbi'开头的数据,不区分大小写
    var bsonwheredata = testdb.Find<Dictionary<string, object>>(autoIDData, "{Name:/^Mongodb/i}");
    
    //****SQL语法和Mongodb查询语法不能混用,简单查询使用SQL语法,书写简单,复杂查询只能使用原生语法。
    //【简写语法】分页查找Qty>10,返回除_id列,按DDATE倒序排序的数据,返回第一页10条数据。
    var pagedata = testdb.GetPagingData<Dictionary<string, object>>(tb_jsondata, "Qty>10",project:"!_id",sort: "!DDATE", pageindex: 1, pagecount: 10);
    
    //【Mongodb语法】分页查找Qty>10,返回除_id列,按DDATE倒序排序的数据,返回第一页10条数据。
    var mgdb_pagedata = testdb.GetPagingData<Dictionary<string, object>>(tb_jsondata, "{Qty:{$gt:10}}", project: "{_id:0}", sort: "{DDATE:-1}", pageindex: 1, pagecount: 10);
    
    //【返回DataTable】分页查找Qty>10,返回除_id列,按DDATE倒序排序的数据,返回第一页10条数据。
    var datatable_pagedata = testdb.GetPagingData(autoIDData, "Qty>10", project: "!_id", sort: "!DDATE", pageindex: 1, pagecount: 10);
   
    //【多条件查询】分页查找Qty>10,返回除_id列,按DDATE倒序排序的数据,返回第一页10条数据。
    var mu_where = testdb.GetPagingData<Dictionary<string, object>>(dictable, "_id>=6 and Qty>10", sort: "!DDATE", pageindex: 1, pagecount: 10);
   
    //【日期范围查询】查找DDATE>='2023-06-05 09:12:24' 和 DDATE<='2023-06-05 13:28:48'的数据。
    var date_result = testdb.GetPagingDataAndResult<Dictionary<string, object>>(dictable, "DDATE>='2023-06-05 09:12:24' and DDATE<='2023-06-05 13:28:48'", sort: "!DDATE", pageindex: 1, pagecount: 10);
    
    //【in查询】查找Qty=200和300的数据。
    var in_result = testdb.GetPagingDataAndResult<Dictionary<string, object>>(dictable, "Qty in(200,300)", sort: "!DDATE", pageindex: 1, pagecount: 10);
   
    //【in模糊查询】查找Name=Batch insert和data结尾的数据。
    var in_fuzzy = testdb.GetPagingDataAndResult<Dictionary<string, object>>(dictable, "Name in('Batch insert','%data')", sort: "!DDATE", pageindex: 1, pagecount: 10);

    //【正则表达式查询】查找Name=Batch开头的数据。
    var in_regex = testdb.GetPagingDataAndResult<Dictionary<string, object>>(dictable, "Name reg'^Batch'", sort: "!DDATE", pageindex: 1, pagecount: 10);s
    //【sql语句查询】查找_id=1的数据
    string sqlcmd = $"select _id,Name,DDATE from {dictable} where _id=1";
    var sqldata = testdb.Find<Dictionary<string, object>>(sqlcmd);
    //【委托查询】查找_id>=6 and Qty>10的数据。数据在委托中返回,方便进行数据处理
    var action_result = testdb.GetPagingDataAction<CrudTestModel1>(dictable, "_id>=6 and Qty>10", datalist => 
    {
        double sum = datalist.Sum(s => s.FFloat);
                
    });

删除数据 delete data

    //**删除ID=8的数据
    var result = testdb.Delete(dictable, 8);

    //**删除qty>10的数据
     var wherresult = testdb.Delete(dictable, "_id>=10");
    //**使用sql语句删除ID = 7的数据,大小写敏感
    string sql = $"delete from {dictable} where _id=7";
    var sqlresult = testdb.Delete(sql);

消息事件绑定(可日志输出)

    public DbTest() {
    t estdb.Message += Testdb_Message;
    }

    private void Testdb_Message((string Message, string Level, DateTime Time) obj)
    {
       Debug.WriteLine($"{obj.Time}|{obj.Level}|{obj.Message}");
    }

增删改查系列包

相关文章

  • 通用曲线控件定制之重点难点篇(附源码,功能丰富灵活) 浮云E绘图
    ​ 上篇已经介绍通用曲线控件源码定制之设计实现,详细描述了通用曲线控件的功能部件及其结构关系,并且实现了核心类的源码,本文由浮云E绘图继续介绍通用曲线控件定制开发的重点和难点,并附完整源码。 一.曲线控件源码类使用流程根据上文通用曲线控件源码定制之设计实现篇可知曲......
  • 通用权限系统-Spring-Boot-Starter
    Spring-Boot-Starter自定义Starter案例一:读取application.yml中的参数1、创建1、创建maven工程hello-spring-boot-starter2、pom中添加依赖<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:......
  • 淘宝直播下载新版教程 一建轻松下载淘宝实时直播和回放视频到本地 通用视频下载器
    2023新版教程来啦!一建轻松下载淘宝直播视频到本地,直播回放也可以下载,支持多任务同时进行没有任务数量限制,操作非常简单最近通用视频下载器软件更新了,很多新用户不知道怎么操作,所以今天给大家出一期教程这样新用户操作起来也会事半功倍!好的,不说废话!我们直接上教程!通用视频下载器可以......
  • 解决MongoDB之Gridfs的具体操作步骤
    MongoDB之GridFS什么是GridFSGridFS是MongoDB的一种存储文件的方式,它可以用于存储和检索大型文件。在传统的MongoDB中,适合存储的文件大小通常限制在16MB以内,而GridFS可以突破这个限制,支持存储非常大的文件。GridFS将大文件分割为小块,每个小块都被存储为一个MongoDB文档。同时,Gri......
  • 如何实现MongoDB 能存储多少张表哦的具体操作步骤
    MongoDB能存储多少张表?概述MongoDB是一种非关系型数据库,采用文档存储方式,并以集合(Collections)来存储数据。在MongoDB中,并不存在传统关系型数据库中的“表”(Table)的概念,而是使用集合来存储文档。在MongoDB中,每个文档都是一个键值对的集合,类似于JSON对象。一个集合中可以......
  • mongodb Aggregates Accumulators使用初步
    importcom.mongodb.BasicDBObject;importcom.mongodb.client.MongoCollection;importcom.mongodb.client.MongoCursor;importcom.mongodb.client.model.Accumulators;importcom.mongodb.client.model.Aggregates;importcom.mongodb.client.model.Filters;importorg.bso......
  • app端——搜索记录mongoDB
    一、需求说明展示用户的搜索记录10条,按照搜索关键词的时间倒序可以删除搜索记录保存历史记录,保存10条,多余的则删除最久的历史记录二、数据存储说明用户的搜索记录,需要给每一个用户都保存一份,数据量较大,要求加载速度快,通常这样的数据存储到mongodb更合适,不建议直接存储到关系......
  • mongodb数据迁移
    mongodb数据迁移操作--备份单个表mongodump-usuperuser-p123456--port27017--authenticationDatabaseadmin-dmyTest-cd-o/backup/mongodb/myTest_d_bak_201507021701.bak--备份单个库mongodump-usuperuser-p123456--port27017--authenticationD......
  • MongoDB随笔
    db    //查询当前使用的数据库showdbs   //查询所有的数据库use【dbname】 //使用数据库  ;如果没有这个数据库会直接创建这个数据库db.createCollection("[collection_name]")   //创建集合(在sql中叫表)例子:db.createCollection("student")在集......
  • EAS_WEB给f7通用查询设置过滤条件
    onCompanyChange:function(event,value){waf('#costDep').wafPromptStandard('option','filteritem',"parent.id='"+value.current.id+"'");waf('#payAccount').......