通过 GBase ADO.NET 接口访问 GBase 数据库，并读 取、更新数据库。

操作数据库

本章节将详细描述如何通过 GBase ADO.NET 接口访问 GBase 数据库，并读 取、更新数据库。

读取数据

通过 GBase ADO.NET 接口读取 GBase Server 数据需要下面的步骤：

1) 使用 GBaseConnection 创建数据库连接对象 2) 使用 GBaseCommand 创建命令对象 3) 使用连接对象打开连接 4) 设置命令对象的 CommandText 属性，指明查询语句，并关联连接对象

GBase 8a 程序员手册 ADO.NET 篇

- 18 - 南大通用数据技术股份有限公司

5) 执行命令对象的 ExecuteReader 方法后返回结果集

 ExecuteReader方法指定 CommandBehavior.SingleResult参数时返回 单个结果集。

 ExecuteReader 方法指定 CommandBehavior.Default 参数时返回多个 结果集。 6) 关闭数据连接

下面的例子将展示如何循环读取某一列的所有数据，并打印出来。 C# 示例： using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Diagnostics; using System.Data; using GBase.Data.GBaseClient; namespace UsingAdoNet { class Program { static void Main(string[] args) { String _ConnStr = "server=192.168.5.41;user id=root;password=1;database=test;pooling=false"; using (GBaseConnection _Conn = new GBaseConnection(_ConnStr)) { try { _ String _CmdText = "select * from `test`.`test`";

GBase 8a 程序员手册 ADO.NET 篇

南大通用数据技术股份有限公司 - 19 -

GBaseCommand cmd = new GBaseCommand(_CmdText, _Conn); _Conn.Open(); GBaseDataReader reader = cmd.ExecuteReader(CommandBehavior.SingleResult); while (reader.Read()) { Console.WriteLine(reader.GetValue(0)); } reader.Close(); } catch (GBaseException ex) { Console.WriteLine(ex.StackTrace); } finally { if( _Conn != null ) _Conn.Close(); } } } } }  

更新数据

通过 GBase ADO.NET 接口修改 GBase Server 数据需要下面的步骤： 1) 使用 GBaseConnection 创建数据库连接对象 2) 使用 GBaseCommand 创建命令对象 3) 使用连接对象打开连接 4) 设置命令对象的 CommandText 属性，指明 SQL 修改语句（Insert 或

Delete 或 Update），并关联连接对象 5) 调用 GBaseCommand 的 ExecuteNonQuery 方法执行 SQL 修改语句 6) 关闭数据库连接 下面的例子将展示如何打开数据库连接，向 test 表插入一条数据，可以使 用同样的步骤 Delete 或者 Update 数据。 C# 示例： using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Diagnostics; using System.Data; using GBase.Data.GBaseClient; namespace UsingAdoNet { class Program { static void Main(string[] args) { String _ConnStr = "server=192.168.5.41;user id=root;password=1;database=test;pooling=false"; using (GBaseConnection _Conn = new GBaseConnection(_ConnStr)) { try { tring _CmdText = "insert into `test`(`varchar_column`) values(‘varchar_value’) "; GBaseCommand _Cmd = new GBaseCommand(_CmdText, _Conn);

_Conn.Open(); _Cmd.ExecuteNonQuery(); } catch (GBaseException ex) { Console.WriteLine(ex.StackTrace); } finally { if( _Conn != null ) _Conn.Close(); } } } } }