commit processing data to database.
10800
protected function CommitProcessData()
    {
        TdbShopSearchFieldWeight::AddQueryBlock(false, null, null);
        $sTmp = serialize($this->aTablesToProcess);
        $aData = $this->sqlData;
        $aData['processdata'] = $sTmp;
        $this->LoadFromRow($aData);
        $this->AllowEditByAll(true);
        $this->Save();
    }
256439
def sync_in_records(self, force=False):
        """"""
        self.log('---- Sync Files ----')

        for f in self.build_source_files:
            f.record_to_objects()

        # Only the metadata needs to be driven to the objects, since the other files are used as code,
        # directly from the file record.
        self.build_source_files.file(File.BSFILE.META).record_to_objects()

        self.commit()
863985
public function commitTransaction()
    {
        // fire model save again, to give Laravel app final chance to finalise anything that needs finalising after
        // batch processing
        foreach (self::$touchList as $model) {
            $model->save();
        }

        DB::commit();
        self::$touchList = [];
        self::$inBatch = false;
    }
981005
protected function postCommit()
    {
        /** @var IDataMapper $dataMapper */
        foreach ($this->dataMappers as $className => $dataMapper) {
            if ($dataMapper instanceof ICachedSqlDataMapper) {
                // Now that the database writes have been committed, we can write to cache
                /** @var ICachedSqlDataMapper $dataMapper */
                $dataMapper->commit();
            }
        }
    }
1305775
public void commit() throws SQLException {
        if (useConnection == null) {
            LOG.info("Commit operation not supported when using datasets unless using withTransaction or cacheConnection - attempt to commit ignored");
            return;
        }
        try {
            useConnection.commit();
        } catch (SQLException e) {
            LOG.warning("Caught exception committing connection: " + e.getMessage());
            throw e;
        }
    }
18177
public function commit() {
        $this->connect();
        if (1 == $this->transTimes) {
            $this->pdo->commit();
        }
        --$this->transTimes;
    }
411087
def commit(self):
        """"""
        if self.session is not None:
            logger.info("committing transaction in %s" % self)
            tmp = self.stable
            self.stable, self.session = self.session, None
            self.istable = 1 - self.istable
            self.write_istable()
            tmp.close() # don't wait for gc, release resources manually
            self.lock_update.release()
        else:
            logger.warning("commit called but there's no open session in %s" % self)
768736
def process_update(self, update):
        """"""
        data = json.loads(update)
        NetworkTables.getEntry(data["k"]).setValue(data["v"])
698259
def processed_records(self, records):
        
        for record in records:
            self.logger.debug('Marking as processed: %s', record)
            record.processed = True
        db.session.commit()
507236
def do_save(self, fp=None):
        
        if fp is not None:
            raise NotImplementedError()
        self.update_main_table()
        self.db.commit()
471048
def _processDML(self, dataset_name, cols, reader):
        """"""
        sql_template = self._generateInsertStatement(dataset_name, cols)

        # Now insert in batch, reader is a list of rows to insert at this point
        c = self.conn.cursor()
        c.executemany(sql_template, reader)
        self.conn.commit()
799037
def update(connection, force_download):
    """"""
    manager.database.update(
        connection=connection,
        force_download=force_download
    )
1220794
def commit(self, sql=None):
        """"""
        self._transaction = False
        try:
            commit = self._con.commit
        except AttributeError:
            return self._con.query(sql or 'commit')
        else:
            if sql:
                return commit(sql=sql)
            else:
                return commit()
443752
def commit(self):
        """"""
        try:
            self._con.commit()
            self._con.autocommit(True)
        except Exception as e:
            try:
                self._con.rollback()
            except Exception as e_:
                LOGGER.error('When transaction happend error: %s', e_)
            raise e
        finally:
            self._db.pool.push(self._con)
            self._con = None
            self._db = None
326492
def process_allow_action(processors, action, argument):
    """"""
    for processor in processors:
        processor(action, argument)
    db.session.commit()
67236
def insert(manager, graph: BELGraph):
    """"""
    to_database(graph, manager=manager, use_tqdm=True)
1213127
def store_many(self, sql, values):
        """"""
        cursor = self.get_cursor()
        cursor.executemany(sql, values)
        self.conn.commit()