GBASE示例分享：将文件写到数据库

本节中的例子会使用一个带有 BLOB 列的表，使用下面的语句生成 file 表。 file_id：表主键，file_name：存储的文件名，file_size：存储文件的大小， file：存储文件内容。

CREATE TABLE file (

file_id SMALLINT UNSIGNED AUTO_INCREMENT NOT NULL PRIMARY KEY,

file_name VARCHAR(64) NOT NULL,

file_size MEDIUMINT UNSIGNED NOT NULL,

file MEDIUMBLOB NOT NULL );

下面的代码使用 FileStream 对象打开一个文件，把文件内容读到一个字节 数组中，并且把它插入到 file 表中。

C# 示例：

using System;

using System.IO;

using GBase.Data.GBaseClient;

namespace UsingGBase

{

class Program

{

static void Main(string[] args)

{

GBaseConnection conn = new GBaseConnection();

GBaseCommand cmd = new GBaseCommand();

string SQL;

int FileSize;

byte[] rawData;

FileStream fs;

string strFileName = @”c:\newfile.png”;

conn.ConnectionString =

“server=192.168.5.41;database=test;user

id=root;password=1;pooling=false”;

try

{

fs = new FileStream(@”c:\test.bmp”, FileMode.Open, FileAccess.Read);

FileSize = (int)fs.Length;

rawData = new byte[FileSize];

fs.Read(rawData, 0, FileSize);

fs.Close();

conn.Open();

SQL = “INSERT INTO file VALUES(NULL, @FileName, @FileSize, @File)”;

cmd.Connection = conn;

cmd.CommandText = SQL;

cmd.Parameters.AddWithValue(“@FileName”, strFileName);

cmd.Parameters.AddWithValue(“@FileSize”, FileSize);

cmd.Parameters.AddWithValue(“@File”, rawData);

cmd.ExecuteNonQuery();

Console.WriteLine(“File Inserted into database successfully!”);

conn.Close();

}

catch (GBaseException ex)

{

Console.WriteLine(“Error ” + ex.Number + ” has occurred: ” + ex.Message);

}

}

}

}

注意：创建表完成后，需要确定 GBase 数据库系统变量 max_allowed_packet 的值，该变量决定能发送给 GBase 服务器的数据包（比如一行）大小。修改 max_allowed_packet 时需注意 BLOB 数据在网络上传输时需要一些时间，应尽量 把该值设为与实际需要相符，并在必要时设置更大值。

要将一个文件写到数据库需要将文件转换为一个字节数组，然后将该字节 数组作为一个 INSERT 语句的参数，通过 GBase ADO.NET 将值写入到表中。