FWD » Core Development » Database

** Module   : ConnectionManager.java

** Abstract : Provides services for logical database connections and aliases

**

**

** -#- -I- --Date-- --JPRM-- ----------------------------Description-----------------------------

** 001 ECF 20051202   @23667 Created initial version. Provides services to

** 055 IAS 20200212          Rework CONNECT and DBPARAM

** 056 ECF 20200419          Removed Hibernate dependencies.

** 057 IAS 20200819          Added table CRUD ops statistics support

*/

/*

import java.text.*;

import java.util.*;

import java.util.Map.*;

import java.util.function.*;

import java.util.logging.*;

import java.util.stream.*;

      boolean inUse = MetadataManager.inUse(MetadataManager._CONNECT) ||

                      MetadataManager.inUse(MetadataManager._MYCONNECTION);

      metaListeners = inUse ? new HashMap<>() : null;

/* Temporary disable _UserTableStat support

      // determine whether we need to initialize a table statistics

   }

   /**

    * Initialize a metaschema database by initializing a connection listener and storing it for

    * later use.

    * <p>

**                           _multiplex sort component matches the index direction.

**     OM  20201120          Adjusted error messages.

**     CA  20210310          A dynamic predicate must set the default lock to NONE, instead of SHARE.

*/

/*

import com.goldencode.p2j.persist.dirty.*;

import com.goldencode.p2j.persist.event.*;

import com.goldencode.p2j.persist.lock.*;

import com.goldencode.p2j.persist.orm.*;

import com.goldencode.p2j.util.*;

import com.goldencode.p2j.util.LogHelper;

                     try

                     {

                        dmo = p.load(buffer.getDMOImplementationClass(), id, lt, timeout, updateLock);

                        break;

                     }

                     catch (LockTimeoutException exc)

                  dmo = p.load(buffer.getDMOImplementationClass(), id, lt, 0L, updateLock);

               }

            }

            if (LOG_FINE)

            {

**     CA  20200924          Replaced Method.invoke with ReflectASM.

**     OM  20201120          Added javadoc note about a possible incorrect logged error.

**     CA  20210310          A dynamic predicate must set the default lock to NONE, instead of SHARE.

*/

/*

import com.goldencode.p2j.persist.dirty.*;

import com.goldencode.p2j.persist.event.*;

import com.goldencode.p2j.persist.lock.*;

import com.goldencode.p2j.persist.orm.*;

import com.goldencode.p2j.util.*;

import com.goldencode.p2j.util.LogHelper;

      buffer.initialize();

      DmoMeta dmoMeta = buffer.getDmoInfo();

      int idxCount = dmoMeta.getIndexCount(true) + dmoMeta.getIndexCount(false);

      if (idxCount > 0)

      this.args = args;

      this.dfArgs = args;

      this.indexInfo = indexInfo;

      {

         this.ffCache = FastFindCache.getInstance(buffer.isTemporary());

      }

         ErrorManager.recordOrThrowError(exc);

      }

      return dmo;

   }

            try

            {

               dmo = persistence.load(buffer.getDMOImplementationClass(), id, lockType, 0L, updateLock);

            }

            catch (MissingRecordException exc)

            {

    *          Database name to be embedded in the connection URL.

    * @param   settings

    *          Object into which to store properties.

    * @return  The populated properties object (same object instance as {@code props}).

    */

   {

      boolean inMem = "jdbc:h2:mem:".equals(JDBC_PREFIX);

      StringBuilder url = new StringBuilder();

** Module   : ConnectTableUpdater.java

** Abstract : Manages metadata connect records for a particular, primary database

**

**

** -#- -I- --Date-- --------------------------------Description----------------------------------

** 001 ECF 20150111 Created initial version.

** 005 ECF 20200906 New ORM implementation.

** 006 IAS 20200819 Added support for additional _Connect table fields.

** 007 CA  20200924 Replaced Method.invoke with ReflectASM.

*/

/*

    */

   public void databaseConnected(int64 connectID)

   {

      {

         return;

      }

** Module   : MetaTableWrapper.java

** Abstract : Wraps data for operations with meta table

**

**

** -#- -I- --Date-- --------------------------------Description----------------------------------

** 001 IAS 20200819 Created initial version.

** 002 CA  20200924 Replaced Method.invoke with ReflectASM.

*/

/*

import java.lang.reflect.*;

import java.util.*;

import java.util.logging.*;

import com.goldencode.p2j.persist.orm.*;

import com.goldencode.p2j.util.*;

import com.goldencode.proxy.*;

   private static final Logger LOG = LogHelper.getLogger(MetaTableWrapper.class);

   /** DMO class */

   /** DMO methods map by name */

   private final Map<Method, Method> methodMap = new HashMap<>();

   /** DMO Impl object */

   private Object dmoImpl;

   /** Meta table DMO proxy */

   private final T metaTableProxy;

   /** DMO operations <code>InvocationHandler</code> */  

   private final InvocationHandler handler = new InvocationHandler() 

   {

    * 

    * @param facet

    *        DMO interface class

    *        DMO interface class simple name 

    */

   {

      try

      {

         {

         }

      } 

      {

      }

   }

   /**

    * 

    * @return DMO interface class

    */

   {

      return dmoClass;

   }

   }

   /**

    * Get meta table DMO proxy 

    * @return meta table DMO proxy

    */

package com.goldencode.p2j.persist.meta;

import java.util.*;

import java.util.concurrent.atomic.*;

import java.util.logging.*;

import com.goldencode.p2j.persist.*;

import com.goldencode.p2j.persist.lock.*;

import com.goldencode.p2j.persist.meta.TableStats.*;

import com.goldencode.p2j.util.*;

/**

 */

public class UserTableStatUpdater

{

   /** MetaUsertablestatImpl DMO wrapper */

   private final MetaTableWrapper<MinimalUsertablestat> usertablestatWrapper = new MetaTableWrapper<>(

   /** MetaUsertablestatImpl DMO proxy */

   private final MinimalUsertablestat usertablestat = usertablestatWrapper.getMetaTableProxy();

   /** meta database */

   private final Database metaDatabase;

   private final Persistence persistence;

   /** Tables' CRUD operations statistics per connection */

   private final AtomicLong databaseVersion = new AtomicLong(-1);

   /** In-memory statistics version */

   private final AtomicLong nextPrimaryKey = new AtomicLong(1);

   /**

    * Constructor

    * 

    */

   public UserTableStatUpdater(Database metaDatabase)

   {

      this.metaDatabase = metaDatabase;

      this.persistence = PersistenceFactory.getInstance(metaDatabase);

   }

   /**

    * Get table statistics holder for a give connection and table

    * 

    * @return table statistics holder

    */

   public TableStats getTableStats(integer connectId, integer tableNo)

   {

   }

    * Persist statistics in the meta database

    * 

    * @return <code>true</code> if success

    */

   {

      {

         return true;

      }

         boolean commit = persistence.beginTransaction();

         Map<integer, Map<integer, Long>> updates = new HashMap<>();

         new Worker().run(updates);

         }

         databaseVersion.set(statVersion);

         // update "persisted" value

         {

            ConcurrentMap<integer, TableStats> cs = tableStats.get(ce.getKey());

            if (ce == null)

            {

               continue;

            }

            {

               TableStats ts = cs.get(te.getKey());

               if (ts != null)

            }

         }

         return true;

         persistence.rollback();

         return false;

   }

   /**

    * Drop data for the closed connection

    */

   public void disconnected(int64 connectId)

   {

      try

      {

         commit = persistence.beginTransaction();

         persistence.flush();

         if (commit)

         {

            commit = false;

            persistence.commit();

         }

      {

         try

         {

            if (commit)

            {

               persistence.rollback();

            }

         {

            LOG.log(Level.WARNING, "Failed to rollback transaction", e);

         }

      }

   }

   /**

    */

   private class Worker

   {

      /**

       * Perform incremental database update

       * 

       * @throws PersistenceException

       */

      {

         {

            {

               Snapshot data = te.getValue().getStat();

               if (data.version <= data.persisted)

               {

                  continue;

               }

               Record dmo = data.persisted < 0 ? 

               persistence.save(dmo, dmo.primaryKey());

            }

         }

      /**

       * Update _usertablestat record

       * @throws PersistenceException

       */

      {

         Record dmo = null;

         if (id != null)

         {

            dmo = persistence.quickLoad(metaIdent);

         }

         if (dmo == null)

         {

         }

         usertablestatWrapper.setDelegate(dmo);

         MinimalUsertablestat proxy = usertablestatWrapper.getMetaTableProxy();

      /**

       * Created _usertablestat record

       * @throws PersistenceException

       */

      {

         Record dmo = null;

         {

            long id = nextPrimaryKey.getAndIncrement();

            dmo.primaryKey(id);

            usertablestatWrapper.setDelegate(dmo);

            proxy.setUsertablestatConn(connId);

            proxy.setUsertablestatNum(tblId);

            populateStat(data, proxy);

         {

            throw new PersistenceException("Error creating meta usertablestat record", e);

         }

         return dmo;

      private void populateStat(Snapshot data, MinimalUsertablestat proxy)

      {

         proxy.setUsertablestatUpdate(new integer(data.update));

         proxy.setUsertablestatDelete(new integer(data.delete));

      }

   }

   /**

    * Interface which defines the minimally required methods of the

    * <code>MinimalUsertablestat</code> interface. This interface defines the proxy

      /**

       * Getter: UserTableStat-Id

       * 

       */

      public int64 getUsertablestatId();

      /**

       * Setter: UserTableStat-Id

       * 

       */

      public void setUsertablestatId(NumberType usertablestatId);

      /**

       * Getter: Connection

       * 

       */

      public integer getUsertablestatConn();

      /**

       * Setter: Connection

       * 

       */

      public void setUsertablestatConn(NumberType usertablestatConn);

      /**

       * Getter: Table #

       * 

       */

      public integer getUsertablestatNum();

      /**

       * Setter: Table #

       * 

       */

      public void setUsertablestatNum(NumberType usertablestatNum);

      /**

       * Getter: read

       * 

       */

      public int64 getUsertablestatRead();

      /**

       * Setter: read

       * 

       */

      public void setUsertablestatRead(NumberType usertablestatRead);

      /**

       * Getter: update

       * 

       */

      public int64 getUsertablestatUpdate();

      /**

       * Setter: update

       * 

       */

      public void setUsertablestatUpdate(NumberType usertablestatUpdate);

      /**

       * Getter: create

       * 

       */

      public int64 getUsertablestatCreate();

      /**

       * Setter: create

       * 

       */

      public void setUsertablestatCreate(NumberType usertablestatCreate);

      /**

       * Getter: delete

       * 

       */

      public int64 getUsertablestatDelete();

      /**

       * Setter: delete

       * 

       */

      public void setUsertablestatDelete(NumberType usertablestatDelete);

      /**

       * Getter: Partition Id

       * 

       */

      public integer getUsertablestatPartitionid();

      /**

       * Setter: Partition Id

       * 

       */

      public void setUsertablestatPartitionid(NumberType usertablestatPartitionid);

      /**

       * Getter: Tenant Id

       * 

       */

      public integer getUsertablestatTenantid();

      /**

       * Setter: Tenant Id

       * 

       */

      public void setUsertablestatTenantid(NumberType usertablestatTenantid);

   }

**     OM  20201202 Added getPrimaryIndex() method.

**     IAS 20201210 Added support for word tables.

**     IAS 20210219 Word tables support for custom extents

*/

/*

import com.goldencode.p2j.persist.annotation.*;

import com.goldencode.p2j.persist.annotation.Table;

import com.goldencode.p2j.persist.dirty.*;

import com.goldencode.p2j.util.*;

import com.google.common.collect.*;

import org.apache.commons.lang3.tuple.*;

import java.lang.reflect.*;

import java.util.*;

      }

      return sb.toString();

   }

   /**

    * Word index data. 

    */

**     IAS 20210315 Use Database instead of schema in constructor, re-work implicit ordering

**     IAS 20210321 Re-worked implicit ordering for word tables. Added implicit sorting for

**                  _temp and 'dirty' databases.

*/

/*

import com.goldencode.p2j.persist.orm.Query.*;

import com.goldencode.p2j.uast.*;

import com.goldencode.p2j.persist.meta.*;

import com.goldencode.p2j.util.*;

import com.goldencode.p2j.util.ErrorManager;

import com.goldencode.p2j.util.LogicalExpressionConverter.*;

            DmoMeta dmoInfo = DmoMetadataManager.getDmoInfo(dmoName, schema);

            if (dmoInfo != null)

            {

               if (alias == null || alias.getType() == ALIAS)

               {

                  String aliasName;

** Abstract : Dispatcher methods for Java language, server-side database

**            functions which replace Progress built-in functions

**

**

** -#- -I- --Date-- --JPRM-- ----------------------------Description-----------------------------

** 001 ECF 20060811   @28584 Created initial version. Backing methods for

** 040 ECF 20200504          Added missing alias for entryIn(Long, String).

** 041 OM  20200212          Unknown value fixes.

** 042 IAS 20201121          Added 'words' functions.

*/

/*

import java.math.*;

import java.sql.*;

import com.goldencode.p2j.*;

import com.goldencode.p2j.util.*;

/**

   }

   /**

    * Rewraps an Integer value into a Long.

    * 

    * @param   i