首页 编程相关 正文
我要发布

南大通用GBase 8s JDBC 中 ROW 类型的应用

编程相关
2025-12-12 0 688

原文链接：www.gbase.cn/community/p…
更多精彩内容尽在南大通用GBase技术社区，南大通用致力于成为用户最信赖的数据库产品供应商。

GBase 8s 提供了对 ROW 类型的支持，这使得在 JDBC 中处理嵌套数据结构变得更为灵活。

ROW 类型是一种复合数据类型，可以包含多个字段，每个字段都有自己的数据类型。在 GBase 8s 中，ROW 类型可以用于定义表的列、程序变量、语句变量以及例程返回值。通过 ROW 类型，可以更直观地表示和操作复杂的数据结构。

准备各个row类型：

CREATE ROW TYPE r1_t (i INT, b BOOLEAN);
CREATE ROW TYPE r2_t (f FLOAT, s MULTISET(INT8 NOT NULL), i INT);
CREATE ROW TYPE fullname_t (first CHAR(20), last CHAR(20));
CREATE ROW TYPE person_t (id INT, name fullname_t, age INT);

 

对应的几个SQLData实现类（只放核心代码）

 

public class r1_t implements SQLData {
   int     int_col;
   boolean bool_col;
   public String toString() {
       String str = \"int_col: \" + int_col + \"    bool_col: \" + bool_col;
       return (str);
   }
}

 

public class r2_t implements SQLData {
   double     dbl_col;
   int        int_col;
   Collection  mset_col;
public void readSQL(SQLInput stream, String typeName) throws SQLException {
       dbl_col = stream.readDouble();
       mset_col = (Collection) ((IfmxComplexSQLInput) stream).readObject();
       int_col = stream.readInt();
   }
   public void writeSQL(SQLOutput stream) throws SQLException {
       stream.writeDouble(dbl_col);
       ((IfmxComplexSQLOutput) stream).writeObject(mset_col);
       stream.writeInt(int_col);
   }
public String toString() {
       String str = \"dbl_col: \" + dbl_col + \"n\";
       str += \"                int_col: \" + int_col + \"n\";
       str += \"                mset_col: n\";
       Iterator it = mset_col.iterator();
       Object element;
       while (it.hasNext()) {
           element = it.next();
           str += \"tttelement: \" + element + \"n\";
       }
       return (str);
   }
}

 

public class fullname implements SQLData {
   public String  first;
   public String  last;
}
public class person implements SQLData {
   public int      id;
   public fullname name;
   public int      age;
   public void readSQL(SQLInput stream, String type) throws SQLException {
   sql_type = type;
   id = stream.readInt();
   name = (fullname) stream.readObject();
   age = stream.readInt();
}
public void writeSQL(SQLOutput stream) throws SQLException {
   stream.writeInt(id);
   stream.writeObject(name);
   stream.writeInt(age);
}
public String toString() {
         String s = \"person:\";
         s += \"id: \" + id + \"n\";
         s += \"     name: \" + name.toString() + \"n\";
         s += \"     age: \" + age + \"n\";
         return s;
     }
}

 

例1：

fetching a named row into a SQLData object
s = \"create table teachers (person person_t, dept char (20))\";
stmt.executeUpdate(s);
s = \"insert into teachers values (\'row(100, row(Bill, Smith), 27)\', \'physics\')\";
stmt.executeUpdate(s);
java.util.Map map = conn.getTypeMap();
map.put(\"fullname_t\", Class.forName(\"com.jdbc.demo.fullname\"));
map.put(\"person_t\", Class.forName(\"com.jdbc.demo.person\"));
pstmt = conn.prepareStatement(\"select person from teachers\");
rs = pstmt.executeQuery();
while (rs.next()) {
   person who = (person) rs.getObject(1);    
   System.out.println(\"row: \" + who.toString());
}

 

输出：

row: person:id: 100
   name: fullname: first: Bill                 last: Smith               
   age: 27

 

例2：

insert java object(SQLData) into a named row column
s = \"create table teachers (person person_t, dept char (20))\";
stmt.executeUpdate(s);
java.util.Map map = conn.getTypeMap();
map.put(\"fullname_t\", Class.forName(\"com.jdbc.demo.fullname\"));
map.put(\"person_t\", Class.forName(\"com.jdbc.demo.person\"));
person who = new person();
fullname name = new fullname();
name.last = \"Jones\";
name.first = \"Sarah\";
who.id = 567;
who.name = name;
who.age = 17;
String s = \"insert into teachers values (?, \'physics\')\";
pstmt = conn.prepareStatement(s);
pstmt.setObject(1, who);
int rowcount = pstmt.executeUpdate();
pstmt = conn.prepareStatement(\"select person::lvarchar from teachers\");
rs = pstmt.executeQuery();
while (rs.next()) {
   String s = rs.getString(1);
System.out.println(\"lvarchar: \" + s);
}

 

输出：

lvarchar: ROW(567        ,ROW(\'Sarah               \',\'Jones               \'),17         )

 

例3：

fetch a unnamed SQLROW column into a Struct object
s = \"create table teachers (person row(id int, name row(first char(20), last char(20)), age int),dept char (20))\";
stmt.executeUpdate(s);
s = \"insert into teachers values (\'row(100, row(Bill, Smith), 27)\', \'physics\')\";
stmt.executeUpdate(s);
pstmt = conn.prepareStatement(\"select person from teachers\");
rs = pstmt.executeQuery();
rs.next();
Struct person = (Struct) rs.getObject(1);
String personRowType = person.getSQLTypeName();
System.out.println(\"person row description: \" + personRowType);
Integer id;
Struct name;
Integer age;
Object[] elements;
elements = person.getAttributes();
id = (Integer) elements[0];
name = (Struct) elements[1];
age = (Integer) elements[2];
System.out.println(\"person.id: \" + id);
System.out.println(\"person.age: \" + age);
String nameRowType = name.getSQLTypeName();
System.out.println(\"name row description: \" + nameRowType);
String first = (String) elements[0];
String last = (String) elements[1];
System.out.println(\"name.first: \" + first);
System.out.println(\"name.last: \" + last);

 

输出：

person row description:  row ( id int , name row ( first char(20) , last char(20) ) , age int ) 
person.id: 100
person.age: 27
name row description: name row ( first char(20) , last char(20) )  // row前的name是列名
name.first: Bill                
name.last: Smith

例4：

inserting a Struct object into a named row
public class GenericStruct implements java.sql.Struct {
   private Object[] attributes = null;
   private String   typeName   = null;
   
   GenericStruct() {
   }
   GenericStruct(String name, Object[] obj) {
       typeName = name;
       attributes = obj;
   }
   public String getSQLTypeName() {
       return typeName;
   }
   public Object[] getAttributes() {
       return attributes;
   }
   public Object[] getAttributes(Map map) throws SQLException {
       return attributes;
   }
   public void setAttributes(Object[] objArray) {
       attributes = objArray;
   }
   public void setSQLTypeName(String name) {
       typeName = name;
   }
}
s = \"create table teachers (person person_t, dept char (20))\";
stmt.executeUpdate(s);
PreparedStatement pstmt;
ResultSet rs;
GenericStruct gs;
String rowType;
pstmt = conn.prepareStatement(\"insert into teachers values (?, \'Math\')\");
Object[] name = new Object[2];
name[0] = new String(\"Jane\");
name[1] = new String(\"Smith\");
rowType = \"row(first char(20), last char(20))\";
gs = new GenericStruct(rowType, name);
Object[] person = new Object[3];
person[0] = new Integer(99);
person[1] = gs;
person[2] = new Integer(56);
rowType = \"row(id int, name row(first char(20), last char(20)), age int)\";
gs = new GenericStruct(rowType, person);
pstmt.setObject(1, gs);
pstmt.executeUpdate();
pstmt.close();
pstmt = conn.prepareStatement(\"select person::lvarchar from teachers\");
rs = pstmt.executeQuery();
while (rs.next()) {
   String s = rs.getString(1);
System.out.println(\"lvarchar: \" + s);
}

 

输出：

lvarchar: ROW(99         ,ROW(\'Jane                \',\'Smith               \'),56         )

例5：

Fetching and inserting a row(i int, b boolean) column
s = \"create table row_tab (int_col int, row_col r1_t)\";
stmt.executeUpdate(s);
s = \"insert into row_tab (int_col, row_col) values (?, ?)\";
pstmt = conn.prepareStatement(s);
java.util.Map customtypemap = conn.getTypeMap();
customtypemap.put(\"r1_t\", Class.forName(\"com.jdbc.demo.r1_t\"));
r1_t row = new r1_t(99, true);
pstmt.setInt(1, 1);
pstmt.setObject(2, row);
pstmt.executeUpdate();
// Select (i) -
// Fetch data using getObject() with customized type maping
s = \"select int_col, row_col from row_tab order by int_col\";
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(s);
rs.next();
int intret = rs.getInt(\"int_col\");
row = (r1_t) rs.getObject(\"row_col\");
System.out.println(row); // 输出：int_col: 99    bool_col: true
// ---------------------------------
// Selecting data as java.sql.Struct 
// ---------------------------------
Vector objVector = new Vector();
String s = \"select int_col, row_col from row_tab order by int_col\";
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(s);
rs.next();
Struct row = (Struct) rs.getObject(\"row_col\", null);
Object[] objArray = row.getAttributes();
for (int i = 0; i < objArray.length; i++) {
   System.out.println(\"ttfield: \" + objArray[i]);
}

输出：

        field: 99
        field: true
// -------------------------------------------------------
// Insert data using java.sql.Struct objects from previous select.
// -------------------------------------------------------
// 清空之前数据，略
s = \"insert into row_tab values (?, ?)\";
pstmt = conn.prepareStatement(s);
for (int i = 0; i < objVector.size(); i++) {
   pstmt.setInt(1, i);
   pstmt.setObject(2, objVector.get(i));
   pstmt.executeUpdate();
}
String s = \"select int_col, row_col::lvarchar from row_tab order by int_col\";
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(s);
rs.next();
System.out.println(rs.getString(2)); // 输出：row_col       ROW(99         ,\'t\')

 

例6：

s = \"create table row_tab (int_col int, row_col r2_t)\";
stmt.executeUpdate(s);
java.util.Map customtypemap = conn.getTypeMap();
customtypemap.put(\"r2_t\", Class.forName(\"r2_t\"));
String s = \"insert into row_tab (int_col, row_col) values (?, ?)\";
pstmt = conn.prepareStatement(s);
TreeSet set = new TreeSet();
set.add(new Long(1234567890));
set.add(new Long(-1234567890));
set.add(new Long(5));
row = new r2_t(1.67e30, set, 99);
pstmt.setInt(1, 1);
pstmt.setObject(2, row);
pstmt.executeUpdate();
String s = \"select int_col, row_col from row_tab order by int_col\";
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(s);
rs.next();
r2_t row = (r2_t) rs.getObject(\"row_col\");
System.out.println(row);

 

输出：

dbl_col: 1.67E30
int_col: 99
mset_col: 
    element: -1234567890
    element: 5
    element: 1234567890

 

例7：

s = \"create table row_tab (int_col int, row_col row(f float, l list(lvarchar not null), i int))\";
stmt.executeUpdate(s);
s = \"insert into row_tab (int_col, row_col) values (?, ?)\";
pstmt = conn.prepareStatement(s);
GenericStruct struct = null; // 同例4的GenericStruct 
Object[] objArray = null;
ArrayList list = null;
list = new ArrayList();
list.add(new String(\"John Smith\"));
list.add(new String(\"Granny Apple\"));
list.add(new String(\"Barry White\"));
objArray = new Object[3];
objArray[0] = new Double(1.67e30);
objArray[1] = list;
objArray[2] = new Integer(99);
struct = new GenericStruct(rowDesc, objArray);
pstmt.setInt(1, 1);
pstmt.setObject(2, struct);
pstmt.executeUpdate();
s = \"select int_col, row_col from row_tab order by int_col\";
rs = stmt.executeQuery(s);
rs.next();
Struct row = (Struct) rs.getObject(\"row_col\");
System.out.println(\"Class: \" + row.getClass().getName());
System.out.println(\"SQLTypeName: \" + row.getSQLTypeName());
Object[] objArray = row.getAttributes();
for (int i = 0; i < objArray.length; i++) {
   System.out.println(\"field: \" + objArray[i]);
}

输出：

Class: com.gbasedbt.jdbc.IfxStruct
SQLTypeName:  row ( f float , l list (  lvarchar not null) , i int ) 
field: -1.67E30
field: [Roger Jones, Jeff Brown]
field: -99

 

本文通过一系列示例展示介绍了如何在 GBase 8s 的 JDBC 环境中使用 ROW 类型。如果你在实践中遇到任何问题，欢迎随时在社区中提问，我们在这里为你提供支持！

原文链接：www.gbase.cn/community/p…
更多精彩内容尽在南大通用GBase技术社区，南大通用致力于成为用户最信赖的数据库产品供应商。

收藏 (0) 打赏

感谢您的支持，我会继续努力的!

打开微信/支付宝扫一扫，即可进行扫码打赏哦，分享从这里开始，精彩与您同在
点赞 (0)

申明：本文由第三方发布，内容仅代表作者观点，与本网站无关。对本文以及其中全部或者部分内容的真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。本网发布或转载文章出于传递更多信息之目的，并不意味着赞同其观点或证实其描述，也不代表本网对其真实性负责。

左子网 编程相关 南大通用GBase 8s JDBC 中 ROW 类型的应用 https://www.zuozi.net/35699.html

开始改变第一天 JVM的原理到调优（2）
上一篇： 开始改变第一天 JVM的原理到调优（2）
南大通用GBase 8c MySQL迁移场景下的时区设置陷阱与解决方案
下一篇： 南大通用GBase 8c MySQL迁移场景下的时区设置陷阱与解决方案
常见问题

发货方式是什么？

  • 1、自动：拍下后，点击（下载）链接即可下载；2、手动：拍下后，联系卖家发放即可或者联系官方找开发者发货。
查看详情

交易周期是多久呢？

  • 1、源码默认交易周期：手动发货商品为1-3天，并且用户付款金额将会进入平台担保直到交易完成或者3-7天即可发放，如遇纠纷无限期延长收款金额直至纠纷解决或者退款！；
查看详情

能退款么？

  • 1、描述：源码描述(含标题)与实际源码不一致的（例：货不对板）； 2、演示：有演示站时，与实际源码小于95%一致的（但描述中有”不保证完全一样、有变化的可能性”类似显著声明的除外）； 3、发货：不发货可无理由退款； 4、安装：免费提供安装服务的源码但卖家不履行的； 5、收费：价格虚标，额外收取其他费用的（但描述中有显著声明或双方交易前有商定的除外）； 6、其他：如质量方面的硬性常规问题BUG等。 注：经核实符合上述任一，均支持退款，但卖家予以积极解决问题则除外。
查看详情

注意事项

  • 1、左子会对双方交易的过程及交易商品的快照进行永久存档，以确保交易的真实、有效、安全！ 2、左子无法对如“永久包更新”、“永久技术支持”等类似交易之后的商家承诺做担保，请买家自行鉴别； 3、在源码同时有网站演示与图片演示，且站演与图演不一致时，默认按图演作为纠纷评判依据（特别声明或有商定除外）； 4、在没有”无任何正当退款依据”的前提下，商品写有”一旦售出，概不支持退款”等类似的声明，视为无效声明； 5、在未拍下前，双方在QQ上所商定的交易内容，亦可成为纠纷评判依据（商定与描述冲突时，商定为准）； 6、因聊天记录可作为纠纷评判依据，故双方联系时，只与对方在左子上所留的QQ、手机号沟通，以防对方不承认自我承诺。 7、虽然交易产生纠纷的几率很小，但一定要保留如聊天记录、手机短信等这样的重要信息，以防产生纠纷时便于左子介入快速处理。
查看详情

相关文章

猜你喜欢
发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务

联系官方团队 在线提交工单
TA的动态
左子网

分享最新WordPress教程共同学习，共同进步，共同成长！

QQ交流群
左子网

QQ交流群

您的支持，是我们最大的动力！ https://qm.qq.com/q/iR7Nj0TrOg
热门文章
热门标签
随机推荐
热门评论
终身VIP会员限时钜惠
首页 源码 菜单 案例 我的