nosql数据库STSDB的一般性使用
nosql
使用
数据库
接着上一篇这里罗列下STSDB的一般性使用 以下内容基于stsdb4.dll（4.0.3.0版本）库（百度分享资源：http://pan.baidu.com/s/1jGxHE3k），截止本文发布，官方最新版本是4.0.5.0，官方地址：http://stsdb.com/ using System;using System.Collections.Generic;
接着上一篇这里罗列下STSDB的一般性使用
以下内容基于stsdb4.dll（4.0.3.0版本）库（百度分享资源：http://pan.baidu.com/s/1jGxHE3k），截止本文发布，官方最新版本是4.0.5.0，官方地址：http://stsdb.com/
using System;
using System.Collections.Generic;
namespace STSDB
{
[Serializable]
public class TStudent
{
public TStudent()
{
}
public string Name { get; set; }
public int Age { get; set; }
public int GroupNumber { get; set; }
public List<TCourse> CourseList { get; set; }
}
}登录后复制
using System;
namespace STSDB
{
[Serializable]
public class TCourse
{
public string CourseName { get; set; }
public string Teacher { get; set; }
public int Score { get; set; }
}
}
登录后复制
/*
* 1. STSdb 4.0 是一个开源的NoSQL 数据库和虚拟文件系统，支持实时索引，完全用c#开发的。
* 引擎原理基于WaterfallTree（瀑布树）数据结构搭建
*
*
* 2.特性
* 支持几十亿级别的数据存取
* 支持TB级别文件大小
* 实时索引
* 内置压缩
* 内置序列化
* 支持稀疏分散的文件（byte[]）
* 存储内存可控
* 支持多线程，且线程安全
* Storage engine instance is thread-safe. Creating (opening) XTable and XFile instances in one storage engine from
different threads is thread-safe.
XTable and XFile instances are also thread-safe. Manipulating different XTable/XFile instances from different threads
is thread-safe.
*
* 3.缺点
* 不支持事务
* 同时处理所有打开的表
*
* 支持多种情况下的数据引擎连接
IStorageEngine engine = STSdb.FromMemory(); //从内存中读取
IStorageEngine engine = STSdb.FromStream(stream); //从数据流中读取
IStorageEngine engine = STSdb.FromHeap(heap); //从堆栈中读取
IStorageEngine engine = STSdb.FromNetwork(host, port); //从远程地址读取
*
*
*/
using System;
using System.IO;
using System.Linq;
using System.Collections.Generic;
namespace STSDB
{
using Newtonsoft.Json;
using STSdb4.Data;
using STSdb4.Database;
using STSdb4.Storage;
using STSdb4.WaterfallTree;
using STSdb4.Remote.Heap;
class Program
{
static void Main(string[] args)
{
ExecuteCode(WriteData);
ExecuteCode(ReadData);
//ExecuteCode(DatabaseSchemeInfo);
//ExecuteCode(ReadItem);
//ExecuteCode(DeleteItems);
//ExecuteCode(ReadItem);
//ExecuteCode(GetRecord);
//ExecuteCode(PageRecord);
//ExecuteCode(Others);
//ExecuteCode(ReNameTable);
//ExecuteCode(ExistsTable);
//ExecuteCode(DeleteTable);
//ExecuteCode(ExistsTable);
#region test
//bool quit = false;
//while (!quit)
//{
// Console.Write("get item data: ");
// string demo = Console.ReadLine();
// switch (demo)
// {
// case "Y":
// break;
// case "Q":
// quit = true;
// break;
// default:
// Console.WriteLine("Choose a Word between Y and Q(to quit)");
// break;
// }
//}
#endregion
Console.ReadKey();
}
/// <summary>执行方法</summary>
static void ExecuteCode(Action act)
{
System.Diagnostics.Stopwatch stopwatch = new System.Diagnostics.Stopwatch();
stopwatch.Start();
act();
stopwatch.Stop();
TimeSpan timespan = stopwatch.Elapsed;
Console.WriteLine("运行{0}秒", timespan.TotalSeconds);
}
/// <summary>
/// 数据库名
/// </summary>
/// <remarks>文件名和扩展名不限制</remarks>
protected static string DataBase = "ClassDB.db";
/// <summary>
/// 学生表名
/// </summary>
protected static string TableName = "tb_student";
/// <summary>
/// 【新】学生表名
/// </summary>
protected static string NewTableName = "new_tb_student";
/// <summary>
/// XFile
/// </summary>
protected static string XFileName = "tb_file";
#region 基本操作
/// <summary>
/// 创建库，写入数据
/// </summary>
static void WriteData()
{
/*
* ①：没有数据库会自动创建的，默认目录和应用程序目录一致；
* ②：打开表，Key支持组合结构 => OpenXTable<TKey, TRecord>
*/
using (IStorageEngine engine = STSdb.FromFile(DataBase)) //①
{
var table = engine.OpenXTable<int, TStudent>(TableName); //②
//var table2 = engine.OpenXTable<TKey, TTick>("table2"); //支持key嵌套
for (int i = 0; i < 1000; i++)
{
table[i] = new TStudent
{
Name = "Jon_" + i.ToString(),
Age = new Random().Next(25, 30),
GroupNumber = i + (new Random().Next(310, 399)),
CourseList = new List<TCourse>()
{
new TCourse{
CourseName="C#高级编程"+i.ToString(),
Teacher="老陈"+i.ToString(),
Score=80
},
new TCourse{
CourseName="C#函数式程序设计"+i.ToString(),
Teacher="老李"+i.ToString(),
Score=90
},
new TCourse{
CourseName="多线程实战应用"+i.ToString(),
Teacher="老张"+i.ToString(),
Score=95
},
}
};
}
engine.Commit();
}
}
/// <summary>
/// 读取数据
/// </summary>
static void ReadData()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
var table = engine.OpenXTable<int, TStudent>(TableName); //ITable:IEnumerable对象
foreach (var item in table)
Console.WriteLine(JsonConvert.SerializeObject(item, Newtonsoft.Json.Formatting.Indented));
Console.WriteLine(table.Count()); //TableName表中有100行数据
}
}
/// <summary>
///
/// </summary>
static void DatabaseSchemeInfo()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase)) //①
{
IDescriptor descriptor = engine[TableName];
Console.WriteLine(descriptor.CreateTime.ToString("yyyy-MM-dd HH:mm:ss"));
Console.WriteLine(descriptor.ModifiedTime.ToString("yyyy-MM-dd HH:mm:ss"));
Console.WriteLine(descriptor.Name);
//ID是表的唯一标识id，表一旦创建，它就创建了，后面只要表在就不会修改
//重建表它会从新分配
Console.WriteLine(descriptor.ID);
//...
}
}
/// <summary>
/// 读取单条数据
/// </summary>
static void ReadItem()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
var table = engine.OpenXTable<int, TStudent>(TableName); //ITable: IEnumerable对象
//var item = table.FirstOrDefault(x => x.Key <= 15 && x.Key >= 10); //key是5的记录
//table[10];
var item = table.FirstOrDefault(x => x.Key == 5); //key是5的记录
if (item.Value != null)
Console.WriteLine(JsonConvert.SerializeObject(item, Newtonsoft.Json.Formatting.Indented));
else
Console.WriteLine("key = 5 的记录不存在！");
//Console.WriteLine("10<= key <= 15 的记录不存在！");
}
}
static void AddItems()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
var table = engine.OpenXTable<int, TStudent>(TableName);
//table[100] = new TStudent(){....};
table.InsertOrIgnore(2, new TStudent());
engine.Commit();
}
}
/// <summary>
/// 删除表数据
/// </summary>
static void DeleteItems()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
var table = engine.OpenXTable<int, TStudent>(TableName); //ITable:IEnumerable对象
if (table != null)
{
//table.Clear(); //清空表数据
table.Delete(5); //删掉key是5的记录
//table.Delete(10, 15); //删掉key从10到15的记录
engine.Commit(); //提交操作，不能少
}
}
}
/// <summary>
/// 按需获取数据
/// </summary>
static void GetRecord()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
/*
Forward向前读取, Backward向后读取, 它们都有2个重载，下面重点说明第二个重载
* Forward(TKey from, bool hasFrom, TKey to, bool hasTo);
* Backward(TKey to, bool hasTo, TKey from, bool hasFrom);
* 超出范围的都不会排除，另外，查询范围超出也不会有影响,但是要注意一点，formkey和endkey的大小关系
*
* 0<----------[(S)]----------------[(E)]------------->N
*
*/
var table = engine.OpenXTable<int, TStudent>(TableName);
var fiterTB = table.Forward(2, true, 9, true); //索引从2到9
//var fiterTB = table.Forward(2, false, 9, true); //索引从0到9
//var fiterTB = table.Forward(2, false, 9, false); //索引从0到表结尾
//var fiterTB = table.Forward(2, true, 9, false); //索引从2到表结尾
//Backward刚好相反
foreach (var item in fiterTB)
Console.WriteLine(JsonConvert.SerializeObject(item, Newtonsoft.Json.Formatting.Indented));
}
}
/// <summary>
/// 数据分页
/// </summary>
static void PageRecord()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
int pageIndex = 2;
int pageSize = 10;
var table = engine.OpenXTable<int, TStudent>(TableName);
var fiterTB = table.Skip(pageSize * (pageIndex - 1)).Take(pageSize);
foreach (var item in fiterTB)
Console.WriteLine(JsonConvert.SerializeObject(item, Newtonsoft.Json.Formatting.Indented));
}
}
/// <summary>
/// 文件数和记录数
/// </summary>
static void Others()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
//表和虚拟文件的数量
Console.WriteLine("数据库 " + DataBase + " 中有 {0} 张表：{1}", engine.Count, TableName);
//表记录数
var table = engine.OpenXTable<int, TStudent>(TableName);
Console.WriteLine("表" + TableName + "中有" + table.Count() + "条记录");
}
}
/// <summary>
/// 表是否存在
/// </summary>
static void ExistsTable()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
//判断表存在与否
//bool exists = engine.Exists(NewTableName);
//Console.WriteLine(NewTableName + " exist?=>{0}", exists.ToString());
bool exists = engine.Exists(TableName);
Console.WriteLine(TableName + " exist?=>{0}", exists.ToString());
}
}
/// <summary>
/// 重命名表名
/// </summary>
static void ReNameTable()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
//判断表存在与否
bool exists = engine.Exists(TableName);
Console.WriteLine(TableName + " exist? =>{0}", exists.ToString());
//表重命名
engine.Rename(TableName, NewTableName);
Console.WriteLine("表" + TableName + "被重命名为：" + NewTableName);
if (engine.Exists(TableName))
Console.WriteLine("old table name \"" + TableName + "\" exist");
if (engine.Exists(NewTableName))
Console.WriteLine("new table name \"" + NewTableName + "\" exist");
}
}
/// <summary>
/// 删除表
/// </summary>
static void DeleteTable()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
//删除表
engine.Delete(TableName);
//engine.Delete(NewTableName);
engine.Commit();
}
}
#endregion
#region XFile
static void TestXFile()
{
using (IStorageEngine engine = STSdb.FromFile(DataBase))
{
XFile file = engine.OpenXFile(XFileName);
Random random = new Random();
byte[] buffer = new byte[] { 1, 2, 3, 4, 5, 6, 7, 8, 9, 10 };
for (int i = 0; i < 100; i++)
{
long position = random.Next();
file.Seek(position, SeekOrigin.Begin);
file.Write(buffer, 0, buffer.Length);
}
engine.Commit();
}
}
//XFile uses special XTable<long, byte[]> implementation to provide effective sparse file functionality.
//One storage engine can have many files
#endregion
#region Client/Server
static void ClientUpdateData()
{
using (IStorageEngine engine = STSdb.FromNetwork("localhost", 7182))
{
ITable<int, string> table = engine.OpenXTable<int, string>("table");
for (int i = 0; i < 100000; i++)
{
table[i] = i.ToString();
}
engine.Commit();
}
}
static void ServerHandleData()
{
string _dbname = "test.stsdb4";
using (IStorageEngine engine = STSdb.FromFile(_dbname))
{
var server = STSdb.CreateServer(engine, 7182);
server.Start();
//server is ready for connections
//server.Stop();
}
}
//The created server instance will listen on the specified port
//and receive/send data from/to the clients
#endregion
#region Memory Usage
/*
min/max children (branches) in each internal (non-leaf) node
max operations in the root node
min/max operations in each internal node
min/max records in each leaf node
number of cached nodes in the memory
*/
static void MemoryUsageHandle()
{
using (StorageEngine engine = (StorageEngine)STSdb.FromFile(DataBase))
{
//下面的demo都是STS.DB的默认值设置
//min/max children (branches) in each internal node
engine.INTERNAL_NODE_MIN_BRANCHES = 2;
engine.INTERNAL_NODE_MAX_BRANCHES = 4;
//max operations in the root node
engine.INTERNAL_NODE_MAX_OPERATIONS_IN_ROOT = 8 * 1024;
//min/max operations in each internal node
engine.INTERNAL_NODE_MIN_OPERATIONS = 64 * 1024;
engine.INTERNAL_NODE_MAX_OPERATIONS = 128 * 1024;
//min/max records in each leaf node
engine.LEAF_NODE_MIN_RECORDS = 16 * 1024;
engine.LEAF_NODE_MAX_RECORDS = 128 * 1024; //at least 2 x MIN_RECORDS
//number of cached nodes in memory
engine.CacheSize = 32;
}
}
#endregion
#region Heap
/*using =>
STSdb4.WaterfallTree;
STSdb4.Storage;
STSdb4.Remote.Heap;
*/
static void HeaperEngine()
{
//Server端
IHeap heap = new Heap(new FileStream("Heap.db", FileMode.OpenOrCreate));
HeapServer server = new HeapServer(heap, 7183); //监听堆服务器
server.Start(); //开始监听
//从远程堆中创建 IStorageEngine 引擎，并处理数据
//using (IStorageEngine engine = STSdb.FromHeap(new RemoteHeap("host", 7183)))
//{
// ITable<int, string> table = engine.OpenXTable<int, string>("table");
// for (int i = 0; i < 100000; i++)
// {
// table[i] = i.ToString();
// }
// engine.Commit();
//}
}
#endregion
//...
}
}
登录后复制
本站声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
热AI工具
Undresser.AI Undress
人工智能驱动的应用程序，用于创建逼真的裸体照片
AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。
Undress AI Tool
免费脱衣服图片
Clothoff.io
AI脱衣机
AI Hentai Generator
免费生成ai无尽的。
热门文章
R.E.P.O.能量晶体解释及其做什么（黄色晶体）
2 周前
By 尊渡假赌尊渡假赌尊渡假赌
仓库：如何复兴队友
4 周前
By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island冒险：如何获得巨型种子
3 周前
By 尊渡假赌尊渡假赌尊渡假赌
击败分裂小说需要多长时间？
3 周前
By DDD
R.E.P.O.保存文件位置：在哪里以及如何保护它？
3 周前
By DDD
热工具
记事本++7.3.1
好用且免费的代码编辑器
SublimeText3汉化版
中文版，非常好用
禅工作室 13.0.1
功能强大的PHP集成开发环境
Dreamweaver CS6
视觉化网页开发工具
SublimeText3 Mac版
神级代码编辑软件(SublimeText3)
网易邮箱大师怎么用
Mar 27, 2024 pm 05:32 PM
网易邮箱，作为中国网民广泛使用的一种电子邮箱，一直以来以其稳定、高效的服务赢得了用户的信赖。而网易邮箱大师，则是专为手机用户打造的邮箱软件，它极大地简化了邮件的收发流程，让我们的邮件处理变得更加便捷。那么网易邮箱大师该如何使用，具体又有哪些功能呢，下文中本站小编将为大家带来详细的内容介绍，希望能帮助到大家！首先，您可以在手机应用商店搜索并下载网易邮箱大师应用。在应用宝或百度手机助手中搜索“网易邮箱大师”，然后按照提示进行安装即可。下载安装完成后，我们打开网易邮箱账号并进行登录，登录界面如下图所示
百度网盘app怎么用
Mar 27, 2024 pm 06:46 PM
在如今云存储已经成为我们日常生活和工作中不可或缺的一部分。百度网盘作为国内领先的云存储服务之一，凭借其强大的存储功能、高效的传输速度以及便捷的操作体验，赢得了广大用户的青睐。而且无论你是想要备份重要文件、分享资料，还是在线观看视频、听取音乐，百度网盘都能满足你的需求。但是很多用户们可能对百度网盘app的具体使用方法还不了解，那么这篇教程就将为大家详细介绍百度网盘app如何使用，还有疑惑的用户们就快来跟着本文详细了解一下吧！百度云网盘怎么用：一、安装首先，下载并安装百度云软件时，请选择自定义安装选
BTCC教学：如何在BTCC交易所绑定使用MetaMask钱包？
Apr 26, 2024 am 09:40 AM
MetaMask（中文也叫小狐狸钱包）是一款免费的、广受好评的加密钱包软件。目前，BTCC已支持绑定MetaMask钱包，绑定后可使用MetaMask钱包进行快速登入，储值、买币等，且首次绑定还可获得20USDT体验金。在BTCCMetaMask钱包教学中，我们将详细介绍如何注册和使用MetaMask，以及如何在BTCC绑定并使用小狐狸钱包。MetaMask钱包是什么？MetaMask小狐狸钱包拥有超过3,000万用户，是当今最受欢迎的加密货币钱包之一。它可免费使用，可作为扩充功能安装在网络
Go语言如何实现数据库的增删改查操作？
Mar 27, 2024 pm 09:39 PM
Go语言是一种高效、简洁且易于学习的编程语言，因其在并发编程和网络编程方面的优势而备受开发者青睐。在实际开发中，数据库操作是不可或缺的一部分，本文将介绍如何使用Go语言实现数据库的增删改查操作。在Go语言中，我们通常使用第三方库来操作数据库，比如常用的sql包、gorm等。这里以sql包为例介绍如何实现数据库的增删改查操作。假设我们使用的是MySQL数据库。
小米汽车app怎么用
Apr 01, 2024 pm 09:19 PM
小米汽车软件提供远程车控功能，让用户可以通过手机或电脑远程控制车辆，例如开关车辆的门窗、启动引擎、控制车辆的空调和音响等，下文就是这个软件的使用及内容，一起了解下吧。小米汽车app功能及使用方法大全1、小米汽车app在3月25日上线苹果AppStore，现在安卓手机的应用商店中也可以下载了;购车：了解小米汽车核心亮点和技术参数，可预约试驾、配置订购您的小米汽车，支持在线处理提车待办事项。3、社区：了解小米汽车品牌资讯，交流用车体验，分享精彩车生活;4、车控：手机就是遥控器，远程控制，实时安防，轻
在PHP中使用MySQLi建立数据库连接的详尽教程
Jun 04, 2024 pm 01:42 PM
如何在PHP中使用MySQLi建立数据库连接：包含MySQLi扩展（require_once）创建连接函数（functionconnect_to_db）调用连接函数（$conn=connect_to_db()）执行查询（$result=$conn->query()）关闭连接（$conn->close()）
Hibernate 如何实现多态映射？
Apr 17, 2024 pm 12:09 PM
Hibernate多态映射可映射继承类到数据库，提供以下映射类型：joined-subclass：为子类创建单独表，包含父类所有列。table-per-class：为子类创建单独表，仅包含子类特有列。union-subclass：类似joined-subclass，但父类表联合所有子类列。
iOS 18 新增'已恢复”相册功能 可找回丢失或损坏的照片
Jul 18, 2024 am 05:48 AM
苹果公司最新发布的iOS18、iPadOS18以及macOSSequoia系统为Photos应用增添了一项重要功能，旨在帮助用户轻松恢复因各种原因丢失或损坏的照片和视频。这项新功能在Photos应用的"工具"部分引入了一个名为"已恢复"的相册，当用户设备中存在未纳入其照片库的图片或视频时，该相册将自动显示。"已恢复"相册的出现为因数据库损坏、相机应用未正确保存至照片库或第三方应用管理照片库时照片和视频丢失提供了解决方案。用户只需简单几步
