GridDB与.NET Core集成可行性技术咨询

我为个人项目及作品集开发了一套完整的员工管理系统，最初采用熟悉的SQL Server数据库。后来决定转向NoSQL数据库GridDB——员工考勤是生物识别设备记录的带时间戳数据，GridDB在这类时序数据的存储与检索上效率更高、速度更优，非常适配这个场景。但查阅官方文档后，我不确定如何实现GridDB与.NET Core的集成，希望得到帮助。

附：我之前连接SQL Server的代码

using Dapper;
using EmployeeManagementDAL.Interface;
using System.Data;
using System.Data.SqlClient;
using EmployeeManagementModels;
using System.ComponentModel.DataAnnotations.Schema;

namespace EmployeeManagementDAL
{
    public class EmployeeRepo : EmployeeRepoInterface
    {
        string connectionString = "Data Source=\"Device Name\";Initial Catalog=EmployeeManagementSystem;User ID=\"admin\";Password=\"admin\"";

        public List<Employee> GetEmployees()
        {
            string output_query = "SELECT [Id], [Name], [Designation], [Department] FROM Employee;";
            IDbConnection connection = null;

            using (connection = new SqlConnection(connectionString))
            {
                if (connection.State != ConnectionState.Open)
                {
                    connection.Open();
                }

                List<Employee> AllEmployees = connection.Query<Employee>(output_query).ToList();
                connection.Close();

                return AllEmployees;
            }
        }

        public void addEmployee(Employee emp)
        {
            DynamicParameters parameters = new DynamicParameters();
            parameters.Add("@Name", emp.Name, DbType.String);
            parameters.Add("@Designation", emp.Designation, DbType.String);
            parameters.Add("@Department", emp.Department, DbType.String);

            string output_query = "INSERT INTO [dbo].[Employee] (Name, Designation, Department) VALUES (@Name, @Designation, @Department);";

            IDbConnection connection = null;

            using (connection = new SqlConnection(connectionString))
            {
                if (connection.State != ConnectionState.Open)
                {
                    connection.Open();
                }

                connection.Query<Employee>(output_query, parameters);
                connection.Close();
            }
        }
    }
}

集成GridDB的具体步骤 #

GridDB官方提供了.NET Core客户端库，可以直接与.NET Core项目集成，以下是适配你现有代码的实现方案：

1. 安装GridDB .NET客户端
   通过NuGet包管理器安装GridDB.Net包，确保版本与你的GridDB服务器版本兼容。

2. 重构数据访问层代码
   GridDB是NoSQL时序数据库，操作逻辑与SQL Server不同，需要先定义容器（对应SQL的表），再进行数据操作。下面是替换后的EmployeeRepo示例：

using GridDB.Net;
using EmployeeManagementDAL.Interface;
using EmployeeManagementModels;
using System.Collections.Generic;
using System.Linq;

namespace EmployeeManagementDAL
{
    public class EmployeeRepo : EmployeeRepoInterface
    {
        // GridDB连接配置
        private readonly string _clusterName = "myCluster";
        private readonly string _user = "admin";
        private readonly string _password = "admin";
        private readonly string _address = "127.0.0.1:10001";

        // 定义容器（对应SQL的Employee表）
        private const string ContainerName = "Employee";

        public List<Employee> GetEmployees()
        {
            var employees = new List<Employee>();

            using (var store = StoreFactory.GetStore())
            {
                // 连接GridDB集群
                var config = new GridDBConfig(_address, _clusterName, _user, _password);
                store.Open(config);

                // 获取容器
                var container = store.GetContainer(ContainerName);

                // 查询所有员工数据
                var query = container.Query("SELECT *");
                using (var rs = query.Fetch())
                {
                    while (rs.HasNext())
                    {
                        var row = rs.Next();
                        employees.Add(new Employee
                        {
                            Id = (long)row.GetValue(0),
                            Name = (string)row.GetValue(1),
                            Designation = (string)row.GetValue(2),
                            Department = (string)row.GetValue(3)
                        });
                    }
                }

                store.Close();
            }

            return employees;
        }

        public void addEmployee(Employee emp)
        {
            using (var store = StoreFactory.GetStore())
            {
                var config = new GridDBConfig(_address, _clusterName, _user, _password);
                store.Open(config);

                var container = store.GetContainer(ContainerName);

                // 创建数据行并插入
                var row = container.CreateRow();
                row.SetValue(1, emp.Name);
                row.SetValue(2, emp.Designation);
                row.SetValue(3, emp.Department);
                container.Put(row);

                store.Close();
            }
        }
    }
}

注意事项 #

• 提前在GridDB中创建好Employee容器，定义好对应的列（Id、Name、Designation、Department），可以通过GridDB的CLI或可视化工具完成。
• 如果需要处理时序考勤数据，可以利用GridDB的时序特性，将考勤数据存储为时间序列容器，进一步优化查询效率。

内容的提问来源于stack exchange，提问作者Ismail