OberonCore

   IMPORT Kernel, SqlDB, StdLog;
   
   CONST
      protocol = "SqlOdbc3";
      id = ""; password = "";
      datasource = "MS_SQL7_TEST_Client";

      TYPE Str1 = RECORD
               id: INTEGER;
               name: ARRAY 32 OF CHAR;
               ceo: ARRAY 32 OF CHAR;
               employees: INTEGER
            END;   
   VAR
      str1*: Str1;

   PROCEDURE Create*;
      VAR db: SqlDB.Database; res: INTEGER;

   BEGIN
      SqlDB.OpenDatabase(protocol, id, password, datasource, SqlDB.async, SqlDB.hideErrors, db, res);
      IF db # NIL THEN
         db.Exec("CREATE TABLE Table1 (id INTEGER, name VARCHAR(32), ceo VARCHAR(32), employees INTEGER)");
         db.Exec("INSERT INTO Table1 VALUES (11, 'Test1', 'qwer', 234)");
         db.Exec("INSERT INTO Table1 VALUES (12, 'Test2', 'qewr-rty', 1234)");

         db.Commit
      END;
      db := NIL;
      Kernel.Cleanup   
   END Create;

   PROCEDURE ReadStr*;
      VAR
         db: SqlDB.Database;
         res: INTEGER;
         table: SqlDB.Table;
         str1: Str1;
         
   BEGIN
      SqlDB.OpenDatabase(protocol, id, password, datasource, SqlDB.async, SqlDB.hideErrors, db, res);
      IF db # NIL THEN
         table := db.NewTable();
         
         table.Exec("SELECT * FROM Table1 WHERE id > 0");
         table.Read(1, str1); ;

         StdLog.Int(str1.id); StdLog.Ln;
         StdLog.String(str1.name); StdLog.Ln;
         StdLog.String(str1.ceo); StdLog.Ln;
         StdLog.Int(str1.employees); StdLog.Ln;

         db.Commit
      END;
      table := NIL;
      db := NIL;
      Kernel.Cleanup;   (* garbage collector closes database *)
   END ReadStr;

TYPE
Str1* = RECORD
   id*: INTEGER;
   name*: ARRAY 32 OF CHAR;
   ceo*: ARRAY 32 OF CHAR;
   employees*: INTEGER
END;

PROCEDURE GenQuery (IN table, type: ARRAY OF CHAR; OUT query: ARRAY OF CHAR);
  VAR r: Meta.Item; s: Meta.Scanner; n: Meta.Name;
BEGIN
  Meta.LookupPath(type, r); ASSERT(r.typ = Meta.recTyp, 20);
  s.ConnectTo(r);
  query := "CREATE TABLE " + table + "(";
  s.Scan;
  WHILE ~s.eos DO
    s.GetObjName(n);
    CASE s.this.typ OF
    ...
    END;
    s.Scan
  END;
  query := query + ")"
END GenQuery;

...
GenQuery("Table1", "Sample.MyRecord", query); db.Exec(query)

   PROCEDURE GenQuery (IN table, type: ARRAY OF CHAR; OUT query: ARRAY OF CHAR);
       VAR r: Meta.Item; s: Meta.Scanner; n: Meta.Name; arrLen, nameType: ARRAY 20 OF CHAR;
   BEGIN
      Meta.LookupPath(type, r); ASSERT(r.typ = Meta.recTyp, 20);
      s.ConnectTo(r);
      query := "CREATE TABLE " + table + " (";
      s.Scan;
      WHILE ~s.eos DO
         s.GetObjName(n);
         CASE s.this.typ OF
            1: nameType := "INTEGER";   (*???*)
            |2: nameType :=  "VARCHAR(1)";   (*???*)
            |3: nameType :=  "VARCHAR(1)";   (*???*)
            |4: nameType :=   "INTEGER";    (*???*)
            |5: nameType :=  "INTEGER";   (*???*)
            |6: nameType :=  "INTEGER";
            |7: nameType :=  "REAL";   (*???*)
            |8: nameType :=  "REAL";
            |10: nameType := "INTEGER";   (*???*)
            |18:
               Strings.IntToString(s.this.Len(), arrLen);
               nameType := "VARCHAR(" + arrLen + ") "; 
         END;

         s.Scan;
         query := query + n + " " + nameType;
         IF ~s.eos THEN query := query + ", " END
      END;
      query := query + ")";
      StdLog.String(query); StdLog.Ln
   END GenQuery;

Meta.boolTyp: nameType := "INTEGER";   (*???*)

......
      TYPE Str3* = RECORD
               name*: ARRAY 32 OF CHAR;
            END;   

......
         table.Exec("SELECT name FROM Table1");
         table.Read(1, str3); (*пытаюсь считать из первой строки значение поля name*)
...............

         table.Exec("SELECT * FROM Table1");
         table.Read(SqlDB.names, names); (*считываем заголовок таблицы*)

         len := LEN(names.fields); pos := -1; i := 0;
         WHILE len > i DO
            IF (names.fields[i]^ = name) THEN pos := i END;
            INC(i);
         END;

         IF pos # -1 THEN
            table.Read(1, row); (*а теперь считываем первую строку таблицы*)
            StdLog.String(row.fields[pos]);
         END;