OberonCore

VAR
   t: SqlDB.Table;
   row: SqlDB.Row;
   i, j: INTEGER;
   ......   
      t.Read(i, row);
      FOR j:= 0 TO LEN(row.fields) - 1 DO
           row.fields[j] ... (* <- во всех полях отсутсвует последний символ*)
      END;

(*Например, при чтении даты-времени, прочитается '2011-03-17 13:00:1' вместо '2011-03-17 13:00:14'*)      
   ......

MODULE MysqlDriver;
   ....
   PROCEDURE (t: Table) ReadVarString   ...
   
   NEW(str, LEN(t.row[column]$) + 1)     (*было NEW(str, LEN(t.row[column]$)*)
   ...

   PROCEDURE (t: Table) Close*, NEW;
   BEGIN
      IF t.open THEN
         t.Cleanup;   (* release table info *)
         IF t.driver#NIL THEN (*ЗДЕСЬ НОВАЯ ПРОВЕРКА*)
            DEC(t.driver.tables);
            IF (t.driver.tables = 0) & ~t.driver.open THEN
               t.driver.Cleanup;   (* release driver info *)
            END;
            t.driver := NIL;   (* allow for garbage collection of driver *)
         END;
         t.open := FALSE;
      END;
   END Close;

      Driver = POINTER TO RECORD (SqlDrivers.Driver)
         ....
         multiple: BOOLEAN
      END;

       (* новая процедура *)
   PROCEDURE GetStatementType (IN statement: ARRAY OF CHAR; OUT op: ARRAY OF CHAR);
      CONST tab = 09X; CR = 0DX; LF = 0AX;
      VAR beg, end: INTEGER;
   BEGIN
      beg := 0;
      WHILE (statement[beg] = ' ') OR (statement[beg] = tab) OR (statement [beg] = CR)
         OR (statement[beg] = LF) DO
         INC(beg)         
      END;
      end := beg;
      WHILE (statement[end] # 0X) & ~( (statement[end] = ' ') OR (statement[end] = tab) OR (statement [end] = CR) OR (statement[end] = LF) ) DO
         INC(end)
      END;
      Strings.Extract(statement, beg, end-beg, op)
   END GetStatementType;

   PROCEDURE (d: Driver) BeginExec (IN statement: ARRAY OF CHAR; data: SqlDrivers.Blob;
                                             async, showErr: BOOLEAN; OUT res: INTEGER);
      VAR ......
            stype: ARRAY 32 OF CHAR;
   BEGIN
....
         GetStatementType(statement, stype);
         d.multiple := (stype = "INSERT") OR (stype = "UPDATE");
         IF d.multiple THEN
            res := Mysql.mysql_set_server_option(d.mysql, Mysql.MYSQL_OPTION_MULTI_STATEMENTS_ON)
         END;
......
   END BeginExec;


   PROCEDURE (d: Driver) EndExec (VAR t: SqlDrivers.Table; OUT rows, columns, res: INTEGER);
   BEGIN
......
      IF ~d.multiple THEN
         resultSet := Mysql.mysql_store_result(d.mysql); (* read the entire result of a query to the client *)
      ELSE
         REPEAT
            resultSet := Mysql.mysql_store_result(d.mysql);
            IF resultSet # NIL THEN
               Mysql.mysql_free_result(resultSet)
            END
         UNTIL Mysql.mysql_next_result(d.mysql) # 0;
         res := Mysql.mysql_set_server_option(d.mysql, Mysql.MYSQL_OPTION_MULTI_STATEMENTS_OFF)
      END;
......