连接ImageDB数据库,需要连接、增删改查操作
时间: 2023-08-18 12:07:09 浏览: 51
好的,以下是您需要的MySQL和C#代码:
MySQL代码:
连接数据库:
```mysql
using System.Data;
using MySql.Data.MySqlClient;
private MySqlConnection conn;
public void ConnectDB()
{
string connStr = "server=localhost;user=root;database=ImageDB;port=3306;password=123456;";
conn = new MySqlConnection(connStr);
try
{
conn.Open();
Console.WriteLine("Database connected!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
增加数据:
```mysql
public void InsertData(string fileName, byte[] image)
{
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "INSERT INTO Image (FileName, ImageData) VALUES (@fileName, @image)";
cmd.Parameters.AddWithValue("@fileName", fileName);
cmd.Parameters.AddWithValue("@image", image);
cmd.ExecuteNonQuery();
Console.WriteLine("Data inserted!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
删除数据:
```mysql
public void DeleteData(int id)
{
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "DELETE FROM Image WHERE Id=@id";
cmd.Parameters.AddWithValue("@id", id);
cmd.ExecuteNonQuery();
Console.WriteLine("Data deleted!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
更新数据:
```mysql
public void UpdateData(int id, string fileName, byte[] image)
{
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "UPDATE Image SET FileName=@fileName, ImageData=@image WHERE Id=@id";
cmd.Parameters.AddWithValue("@id", id);
cmd.Parameters.AddWithValue("@fileName", fileName);
cmd.Parameters.AddWithValue("@image", image);
cmd.ExecuteNonQuery();
Console.WriteLine("Data updated!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
查询数据:
```mysql
public DataTable SelectData()
{
DataTable dt = new DataTable();
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "SELECT * FROM Image";
MySqlDataAdapter da = new MySqlDataAdapter(cmd);
da.Fill(dt);
Console.WriteLine("Data selected!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
return dt;
}
```
C#代码:
连接数据库:
```csharp
using System.Data;
using MySql.Data.MySqlClient;
private MySqlConnection conn;
public void ConnectDB()
{
string connStr = "server=localhost;user=root;database=ImageDB;port=3306;password=123456;";
conn = new MySqlConnection(connStr);
try
{
conn.Open();
Console.WriteLine("Database connected!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
增加数据:
```csharp
public void InsertData(string fileName, byte[] image)
{
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "INSERT INTO Image (FileName, ImageData) VALUES (@fileName, @image)";
cmd.Parameters.AddWithValue("@fileName", fileName);
cmd.Parameters.AddWithValue("@image", image);
cmd.ExecuteNonQuery();
Console.WriteLine("Data inserted!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
删除数据:
```csharp
public void DeleteData(int id)
{
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "DELETE FROM Image WHERE Id=@id";
cmd.Parameters.AddWithValue("@id", id);
cmd.ExecuteNonQuery();
Console.WriteLine("Data deleted!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
更新数据:
```csharp
public void UpdateData(int id, string fileName, byte[] image)
{
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "UPDATE Image SET FileName=@fileName, ImageData=@image WHERE Id=@id";
cmd.Parameters.AddWithValue("@id", id);
cmd.Parameters.AddWithValue("@fileName", fileName);
cmd.Parameters.AddWithValue("@image", image);
cmd.ExecuteNonQuery();
Console.WriteLine("Data updated!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
}
```
查询数据:
```csharp
public DataTable SelectData()
{
DataTable dt = new DataTable();
try
{
MySqlCommand cmd = new MySqlCommand();
cmd.Connection = conn;
cmd.CommandText = "SELECT * FROM Image";
MySqlDataAdapter da = new MySqlDataAdapter(cmd);
da.Fill(dt);
Console.WriteLine("Data selected!");
}
catch (Exception ex)
{
Console.WriteLine(ex.ToString());
}
return dt;
}
```