Branch data     Line data    Source code

       1                 :             : #include <stdlib.h>
       2                 :             : #include <string.h>
       3                 :             : #include <stdio.h>
       4                 :             : 
       5                 :             : exec sql include ../regression;
       6                 :             : 
       7                 :             : exec sql whenever sqlerror sqlprint;
       8                 :             : 
       9                 :             : int
      10                 :           2 : main(void)
      11                 :             : {
      12                 :             : exec sql begin declare section;
      13                 :             :     char command[512];
      14                 :             :     char search_address[10];
      15                 :             :     char cname[100];
      16                 :             :     int reg;
      17                 :             : exec sql end declare section;
      18                 :             : 
      19                 :           2 :     ECPGdebug(1, stderr);
      20                 :             : 
      21                 :           2 :     exec sql connect to REGRESSDB1 as main;
      22         [ -  + ]:           2 : 
      23                 :             :     /* Create schema and tables for property graph testing */
      24                 :           2 :     exec sql create schema graph_ecpg_tests;
      25         [ -  + ]:           2 :     exec sql set search_path = graph_ecpg_tests;
      26         [ -  + ]:           2 : 
      27                 :           2 :     exec sql create table customers (
      28                 :             :         customer_id integer primary key,
      29                 :             :         name varchar,
      30                 :             :         address varchar
      31                 :             :     );
      32         [ -  + ]:           2 : 
      33                 :           2 :     exec sql create table orders (
      34                 :             :         order_id integer primary key,
      35                 :             :         register integer
      36                 :             :     );
      37         [ -  + ]:           2 : 
      38                 :           2 :     exec sql create table customer_orders (
      39                 :             :         customer_orders_id integer primary key,
      40                 :             :         customer_id integer references customers (customer_id),
      41                 :             :         order_id integer references orders (order_id)
      42                 :             :     );
      43         [ -  + ]:           2 : 
      44                 :             :     /* Insert test data */
      45                 :           2 :     exec sql insert into customers values (1, 'customer1', 'US'), (2, 'customer2', 'CA'), (3, 'customer3', 'GL');
      46         [ -  + ]:           2 :     exec sql insert into orders values (1, 100), (2, 200), (3, 500);
      47         [ -  + ]:           2 :     exec sql insert into customer_orders (customer_orders_id, customer_id, order_id) values (1, 1, 1), (2, 2, 2), (3, 3, 3);
      48         [ -  + ]:           2 : 
      49                 :             :     /* Create property graph */
      50                 :           2 :     exec sql create property graph shopgraph
      51                 :             :         vertex tables (
      52                 :             :             customers,
      53                 :             :             orders
      54                 :             :         )
      55                 :             :         edge tables (
      56                 :             :             customer_orders key (customer_orders_id)
      57                 :             :                 source key (customer_id) references customers (customer_id)
      58                 :             :                 destination key (order_id) references orders (order_id)
      59                 :             :         );
      60         [ -  + ]:           2 : 
      61                 :           2 :     exec sql commit;
      62         [ -  + ]:           2 : 
      63                 :             :     /* direct sql - US customers */
      64                 :           2 :     exec sql select * into :cname, :reg from graph_table (shopgraph match (c is customers where c.address = 'US')-[is customer_orders]->(o is orders) columns (c.name, o.register));
      65         [ -  + ]:           2 :     printf("found %ld results (%s, %d)\n", sqlca.sqlerrd[2], cname, reg);
      66                 :             : 
      67                 :             :     /* direct sql with C variable - GL customers */
      68                 :           2 :     strcpy(search_address, "GL");
      69                 :           2 :     exec sql select * into :cname, :reg from graph_table (shopgraph match (c is customers where c.address = :search_address)-[is customer_orders]->(o is orders) columns (c.name, o.register));
      70         [ -  + ]:           2 :     printf("found %ld results (%s, %d)\n", sqlca.sqlerrd[2], cname, reg);
      71                 :             : 
      72                 :             :     /* prepared statement - CA customers */
      73                 :           2 :     sprintf(command, "select * from graph_table (shopgraph match (c is customers where c.address = $1)-[is customer_orders]->(o is orders) columns (c.name, o.register))");
      74                 :           2 :     exec sql prepare graph_stmt from :command;
      75         [ -  + ]:           2 :     strcpy(search_address, "CA");
      76                 :           2 :     exec sql execute graph_stmt into :cname, :reg using :search_address;
      77         [ -  + ]:           2 :     printf("found %ld results (%s, %d)\n", sqlca.sqlerrd[2], cname, reg);
      78                 :           2 :     exec sql deallocate graph_stmt;
      79         [ -  + ]:           2 : 
      80                 :             :     /* cursor test - all customers with orders */
      81                 :             :     exec sql declare graph_cursor cursor for select * from graph_table (shopgraph match (c is customers)-[is customer_orders]->(o is orders) columns (c.name, o.register)) order by name;
      82                 :           2 :     exec sql open graph_cursor;
      83         [ -  + ]:           2 :     exec sql whenever not found do break;
      84                 :             :     while (1) {
      85                 :           8 :         exec sql fetch graph_cursor into :cname, :reg;
      86   [ +  +  -  + ]:           8 :         printf("cursor result: %s, %d\n", cname, reg);
      87                 :             :     }
      88                 :             :     exec sql whenever not found continue;
      89                 :           2 :     exec sql close graph_cursor;
      90         [ -  + ]:           2 : 
      91                 :             :     /* label disjunction syntax test */
      92                 :           2 :     exec sql select * into :cname from graph_table (shopgraph match (c is customers | customers where c.address = 'US') columns (c.name));
      93         [ -  + ]:           2 :     printf("found %ld results (%s)\n", sqlca.sqlerrd[2], cname);
      94                 :             : 
      95                 :             :     /* Clean up */
      96                 :           2 :     exec sql drop property graph shopgraph;
      97         [ -  + ]:           2 :     exec sql drop table customer_orders;
      98         [ -  + ]:           2 :     exec sql drop table orders;
      99         [ -  + ]:           2 :     exec sql drop table customers;
     100         [ -  + ]:           2 :     exec sql drop schema graph_ecpg_tests;
     101         [ -  + ]:           2 :     exec sql commit;
     102         [ -  + ]:           2 :     exec sql disconnect;
     103         [ -  + ]:           2 : 
     104                 :           2 :     return 0;
     105                 :             : }