wimms.sql.SQLMetadata._safe_execute

All Samples(3) | Call(3) | Derive(0) | Import(0)

Execute an sqlalchemy query, raise BackendError on failure.

src/w/i/wimms-0.3/wimms/shardedsql.py wimms(Download)

            table = elements[PATTERNS_INDEX]
            try:
                results = self._safe_execute(select([table]), engine=engine)
            except BackendError:
                continue

src/t/o/tokenserver-HEAD/loadtest/populate-db.py tokenserver(Download)

        email = "%s@%s" % (idx, host)
        node = random.choice(nodes)
        md._safe_execute(_CREATE_USER_RECORD, email=email, node=node, **params)

src/w/i/wimms-0.3/wimms/tests/test_sql.py wimms(Download)

              """insert into nodes (`id`, `node`, `service`, `available`,
                    `capacity`, `current_load`, `downed`, `backoff`)
                values (1, "https://phx12", "sync-1.0", 100, 100, 0, 0, 0)""")
 
        self._sqlite = self.backend._engine.driver == 'pysqlite'