C# doris 数据库写数据

在C#中向Doris数据库写入数据，通常需要通过HTTP接口或者JDBC/ODBC连接来实现。Doris提供了一个基于HTTP的Stream Load接口，可以用于数据导入[^1]。此外，也可以通过MySQL协议连接Doris，然后执行INSERT语句插入数据[^2]。 ### 使用HTTP Stream Load写入数据 Doris的Stream Load接口允许用户通过HTTP请求将数据以流式方式上传到Doris中。以下是一个使用C#发送HTTP POST请求将CSV数据写入Doris的示例： ```csharp using System; using System.Net.Http; using System.Text; using System.Threading.Tasks; class Program { static async Task Main(string[] args) { var client = new HttpClient(); var url = "http://<doris-be-host>:8030/api/<database>/<table>/_stream_load"; // 设置Basic Auth凭证（用户名和密码） var byteArray = Encoding.ASCII.GetBytes("<username>:<password>"); client.DefaultRequestHeaders.Authorization = new System.Net.Http.Headers.AuthenticationHeaderValue("Basic", Convert.ToBase64String(byteArray)); // CSV数据 var csvData = "1,John Doe,30\n2,Jane Doe,25"; // 构建请求内容 var content = new StringContent(csvData, Encoding.UTF8, "text/plain"); // 设置自定义Header（可选） content.Headers.Add("label", "stream_load_example"); content.Headers.Add("column_separator", ","); // 发送POST请求 var response = await client.PostAsync(url, content); var responseString = await response.Content.ReadAsStringAsync(); Console.WriteLine(responseString); } } ``` 请将`<doris-be-host>`、`<database>`、`<table>`、`<username>`和`<password>`替换为实际的Doris后端地址、数据库名、表名、用户名和密码。 ### 使用MySQL协议写入数据 Doris支持MySQL协议，因此可以使用C#中的MySQL连接库（如`MySql.Data.MySqlClient`）来连接Doris并执行SQL语句。 #### 安装MySQL连接库 可以通过NuGet安装MySQL连接库： ```bash Install-Package MySql.Data ``` #### 示例代码 ```csharp using System; using MySql.Data.MySqlClient; class Program { static void Main() { string connectionString = "server=<doris-mysql-host>;port=9030;database=<database>;uid=<username>;password=<password>;"; using (MySqlConnection conn = new MySqlConnection(connectionString)) { try { conn.Open(); string query = "INSERT INTO <table> (id, name, age) VALUES (1, 'John Doe', 30)"; MySqlCommand cmd = new MySqlCommand(query, conn); cmd.ExecuteNonQuery(); Console.WriteLine("Data inserted successfully."); } catch (Exception ex) { Console.WriteLine("Error: " + ex.Message); } } } } ``` 同样，请将`<doris-mysql-host>`、`<database>`、`<table>`、`<username>`和`<password>`替换为实际的Doris MySQL服务地址、数据库名、表名、用户名和密码。 ### 注意事项 - **性能优化**：对于大批量数据插入，建议使用批量插入或使用Doris的Stream Load接口，以提高性能[^3]。 - **事务支持**：如果需要事务支持，确保使用支持事务的连接方式，并正确配置Doris表为支持事务的类型（如Unique Key模型）[^4]。 - **数据格式**：根据数据格式（如CSV、JSON等），选择合适的导入方式，并在Stream Load请求中指定相应的`format`参数[^5]。