当前位置：首页 > 行业动态 > 正文

如何在C中将对象存储到数据库？

admin
行业动态
2025-01-15
1

在 C# 中，可以使用对象关系映射（ORM）工具如 Entity Framework 将对象存储到数据库。

在C#中，将对象存入数据库通常涉及以下几个步骤：序列化对象、建立数据库连接、创建表（如果尚未存在）、插入数据，这里我们将详细讨论这一过程，并以一个具体的例子来说明如何操作。

序列化对象

在将对象存入数据库之前，我们需要将对象序列化为一种可以存储的格式，如JSON、XML等，在C#中，我们可以使用System.Text.Json或Newtonsoft.Json库来序列化对象。

using System;
using System.Text.Json;
public class Person
{
    public string Name { get; set; }
    public int Age { get; set; }
}
class Program
{
    static void Main()
    {
        Person person = new Person { Name = "John Doe", Age = 30 };
        string jsonString = JsonSerializer.Serialize(person);
        Console.WriteLine(jsonString);
    }
}

建立数据库连接

我们需要建立与数据库的连接，这里以SQL Server为例，使用System.Data.SqlClient来连接数据库。

using System;
using System.Data.SqlClient;
class Program
{
    static void Main()
    {
        string connectionString = "Server=localhost;Database=TestDB;User Id=myUsername;Password=myPassword;";
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            Console.WriteLine("Database connection opened.");
        }
    }
}

创建表（如果尚未存在）

在插入数据之前，确保数据库中存在相应的表，如果表不存在，我们需要先创建它。

CREATE TABLE Persons (
    Id INT PRIMARY KEY IDENTITY,
    Name NVARCHAR(50),
    Age INT,
    Data NVARCHAR(MAX)
);

插入数据

我们将序列化后的对象作为字符串插入到数据库中。

using System;
using System.Data.SqlClient;
using System.Text.Json;
public class Person
{
    public string Name { get; set; }
    public int Age { get; set; }
}
class Program
{
    static void Main()
    {
        string connectionString = "Server=localhost;Database=TestDB;User Id=myUsername;Password=myPassword;";
        Person person = new Person { Name = "John Doe", Age = 30 };
        string jsonString = JsonSerializer.Serialize(person);
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            connection.Open();
            string query = "INSERT INTO Persons (Name, Age, Data) VALUES (@Name, @Age, @Data)";
            using (SqlCommand command = new SqlCommand(query, connection))
            {
                command.Parameters.AddWithValue("@Name", person.Name);
                command.Parameters.AddWithValue("@Age", person.Age);
                command.Parameters.AddWithValue("@Data", jsonString);
                int result = command.ExecuteNonQuery();
                Console.WriteLine($"{result} rows inserted.");
            }
        }
    }
}