OberonCore

MODULE DbTest2;

   IMPORT ObxRandom, (*MysqlLibWin, *)Math, Files, Dates, (*Services, *)Strings, (*MysqlStrings, *)SqlDB, SqlDrivers, Dialog, (*Mysql := MysqlDriver, *)Log := StdLog;

   CONST
      protocol = 'MysqlDriver';
      host = 'localhost';
      dbName = 'test2';
      user = 'root'+':'+dbName;
      pwd = 'ghbdtn';
      port = 0;
      client_flag = {};
      
   TYPE
      ReadRec = RECORD
      id*: INTEGER;
      name*: ARRAY 51 OF CHAR;
      value*: INTEGER;
   END;

   VAR
      db: SqlDB.Database;
      rec*: RECORD
      id: INTEGER;
      name: ARRAY 51 OF CHAR;
      value: INTEGER;
   END;
      
   table*: SqlDB.Table;
   
   PROCEDURE Connect*;
      VAR res: INTEGER;
   BEGIN
      SqlDB.OpenDatabase(protocol, user, pwd, host, SqlDB.sync, SqlDB.showErrors, db, res);
      table := db.NewTable();
      Log.String("Подключение к базе выполнено");Log.Ln;
   END Connect;
   
   PROCEDURE Create*;
      VAR
   BEGIN
      db.Exec("CREATE TABLE proba (id INT, name VARCHAR(255), value INT)");
      db.Exec("INSERT INTO proba VALUES ('1', 'usluga 1', '310')");
      db.Exec("INSERT INTO proba VALUES ('2', 'usluga 2', '230')");
      db.Exec("INSERT INTO proba VALUES ('3', 'usluga 3', '450')");
      db.Commit
   END Create;
   
   PROCEDURE Del*;
      VAR
   BEGIN
      db.Exec("drop table proba");
      Log.String("Tables Delete");Log.Ln;
   END Del;
   
   PROCEDURE Show*;
      BEGIN
      table.Exec("SELECT * FROM proba");
      Dialog.Update(table);
   END Show;
END DbTest2.
^QDbTest2.Connect
^QDbTest2.Create
^QDbTest2.Del
^QDbTest2.Show