支持GBase UP 的Blob Uri 字段的存取，使用时注意以下几点要求：
必须使用Prepare
必须使用Parameters
大文件必须使用FileStream 作为Parameters 的参数
Select 时必须将Blob Uri 字段放在所有字段最后
Select 时DataReader 必须使用CommandBehavior.SequentialAccess
流式读取模式
Select 时先执行GetBlobLength()获取Blob
Uri 字段值的长度，
再循
环执行GetBlob 获取
使用代码示例如下：
string connstr =
"server=192.168.8.29;database=song;uid=gbase;pwd=gbase20110531;pooling=false;
Ignore Prepare=false;";//连接参数中必须指定Ignore Prepare=false
FileStream fsin;
string filepath = @"d:\1.bmp";
string tablename = "test1";
fsin = new FileStream(filepath,FileMode.Open,FileAccess.Read);
long fsinlength = fsin.Length;
string sql = "drop table if exists " + tablename;
using (GBaseConnection conn = new GBaseConnection(connstr))
{
conn.Open();
GBase 8a 程序员手册ADO.NET 篇
南大通用数据技术股份有限公司
- 337 -
using (GBaseCommand cmd = new GBaseCommand(sql,conn))
{
cmd.ExecuteNonQuery();
cmd.CommandText = "create table " + tablename + " (a int, b blob uri, c
varchar(30))";
cmd.ExecuteNonQuery();
cmd.CommandText = "insert into " + tablename + " values(@a,@b,@c)";
cmd.CommandTimeout = 20000;
cmd.Parameters.AddWithValue("@a", 1);
cmd.Parameters.AddWithValue("@b", fsin); //将FileStream作为参数传入
cmd.Parameters.AddWithValue("@c", "song");
cmd.Prepare();//必须先Prepare
cmd.ExecuteNonQuery();
}
fsin.Close();
FileStream fsout;
string outpath = @"d:\outfile.bmp";
if (File.Exists(outpath))
{
File.Delete(outpath);
}
fsout = new FileStream(outpath, FileMode.OpenOrCreate, FileAccess.Write);
sql = "select a,c,b from " + tablename; //select时将blob uri字段放在最后
using (GBaseCommand cmd = new GBaseCommand(sql,conn))
{
cmd.Prepare();//开启prepare
cmd.CommandTimeout = 20000;//timeout设置大，防止在读取较大数据
时超时退出
GBase 8a 程序员手册ADO.NET 篇
- 338 -
南大通用数据技术股份有限公司
using (GBaseDataReader reader =
cmd.ExecuteReader(CommandBehavior.SequentialAccess)) //必须设置为流式读取
{
while (reader.Read())
{
Assert.AreEqual(1, reader.GetValue(0));
Assert.AreEqual("song", reader.GetValue(1));
long len = 0;
len = reader.GetBlobLength(2);//读取blob uri时，先获取列值的
长度 GetBlobLength
if (len == 0)
{
Console.WriteLine("blob uri is null");
}
Assert.AreEqual(len, fsinlength);//判断获取的长度等于存入时
的长度
byte[] result = null;
long alreadyRead = 0;//已经读取的长度
while (alreadyRead < len)//循环获取值
{
result = reader.GetBlob(2, alreadyRead); //读满，一个数据
包最大16M，内存够用 GetBlob
fsout.Write(result, 0, result.Length);
alreadyRead += result.Length;
}
fsout.Close();
}
}
}
}