Lines Matching refs:cx
44 cx = sqlite.connect(":memory:", *args, **kwargs)
45 return contextlib.closing(cx)
50 def cx_limit(cx, category=sqlite.SQLITE_LIMIT_SQL_LENGTH, limit=128):
52 _prev = cx.setlimit(category, limit)
55 cx.setlimit(category, _prev)
346 cx = sqlite.connect(":memory:")
347 check_disallow_instantiation(self, type(cx("select 1")))
358 self.cx = sqlite.connect(":memory:")
359 cu = self.cx.cursor()
364 self.cx.close()
367 self.cx.commit()
373 self.cx.commit()
374 self.cx.commit()
377 self.cx.rollback()
383 self.cx.rollback()
384 self.cx.rollback()
387 cu = self.cx.cursor()
395 self.cx.close()
399 cu = self.cx.cursor()
401 self.cx.close()
406 self.assertRaises(sqlite.ProgrammingError, self.cx.execute, sql)
408 self.cx.executemany, sql, [])
409 self.assertRaises(sqlite.ProgrammingError, self.cx.executescript, sql)
411 self.cx.create_function, "t", 1, lambda x: x)
412 self.assertRaises(sqlite.ProgrammingError, self.cx.cursor)
414 with self.cx:
419 self.assertEqual(self.cx.Warning, sqlite.Warning)
420 self.assertEqual(self.cx.Error, sqlite.Error)
421 self.assertEqual(self.cx.InterfaceError, sqlite.InterfaceError)
422 self.assertEqual(self.cx.DatabaseError, sqlite.DatabaseError)
423 self.assertEqual(self.cx.DataError, sqlite.DataError)
424 self.assertEqual(self.cx.OperationalError, sqlite.OperationalError)
425 self.assertEqual(self.cx.IntegrityError, sqlite.IntegrityError)
426 self.assertEqual(self.cx.InternalError, sqlite.InternalError)
427 self.assertEqual(self.cx.ProgrammingError, sqlite.ProgrammingError)
428 self.assertEqual(self.cx.NotSupportedError, sqlite.NotSupportedError)
432 cx = sqlite.connect(":memory:")
433 cu = cx.cursor()
434 self.assertEqual(cx.in_transaction, False)
436 self.assertEqual(cx.in_transaction, False)
438 self.assertEqual(cx.in_transaction, True)
441 self.assertEqual(cx.in_transaction, True)
442 cx.commit()
443 self.assertEqual(cx.in_transaction, False)
446 self.assertEqual(cx.in_transaction, False)
450 self.cx.in_transaction = True
466 self.assertTrue(hasattr(self.cx, exc))
467 self.assertIs(getattr(sqlite, exc), getattr(self.cx, exc))
470 cx = sqlite.connect(":memory:")
471 cx.close()
473 cx.interrupt()
476 self.assertIsNone(self.cx.interrupt())
480 cu = self.cx.execute(f"select {n}")
485 saved_limit = self.cx.getlimit(category)
488 prev_limit = self.cx.setlimit(category, new_limit)
490 self.assertEqual(self.cx.getlimit(category), new_limit)
493 self.cx.execute, "select 1 as '16'")
495 self.cx.setlimit(category, saved_limit)
501 self.cx.getlimit, cat)
503 self.cx.setlimit, cat, 0)
524 with memory_database() as cx:
526 cx.isolation_level = level
528 self.assertEqual(cx.isolation_level, "")
533 with memory_database(isolation_level=level) as cx:
534 self.assertEqual(cx.isolation_level, level)
535 with memory_database() as cx:
536 self.assertEqual(cx.isolation_level, "")
537 cx.isolation_level = level
538 self.assertEqual(cx.isolation_level, level)
542 cx = sqlite.connect(db)
543 cx.text_factory = bytes
544 cx.row_factory = sqlite.Row
545 cu = cx.cursor()
555 cx.__init__(db)
556 cx.execute("create table foo (bar)")
557 cx.executemany("insert into foo (bar) values (?)",
566 cx = sqlite.connect(":memory:")
567 with cx:
568 cx.execute("create table t(t)")
572 cx.__init__, db)
575 cx.executemany, "insert into t values(?)",
581 self.cx = sqlite.Connection.__new__(sqlite.Connection)
585 lambda: self.cx.isolation_level,
586 lambda: self.cx.total_changes,
587 lambda: self.cx.in_transaction,
588 lambda: self.cx.iterdump(),
589 lambda: self.cx.cursor(),
590 lambda: self.cx.close(),
603 with memory_database() as cx:
604 with cx:
605 cx.execute("create table t(t)")
606 data = cx.serialize()
609 with cx:
610 cx.execute("drop table t")
613 cx.execute("select t from t")
616 cx.deserialize(data)
617 cx.execute("select t from t")
628 with memory_database() as cx:
629 self.assertRaises(exc, cx.deserialize, arg)
632 with memory_database() as cx:
635 cx.deserialize(b"\0\1\3")
638 cx.execute("create table fail(f)")
643 with memory_database() as cx:
645 cx.deserialize(b"b" * size)
657 with contextlib.closing(sqlite.connect(path)) as cx:
659 cx.execute(self._sql)
669 with contextlib.closing(sqlite.connect(path)) as cx:
671 cx.execute(self._sql)
678 with contextlib.closing(sqlite.connect(uri, uri=True)) as cx:
680 cx.execute(self._sql)
687 with contextlib.closing(sqlite.connect(uri, uri=True)) as cx:
689 cx.execute(self._sql)
703 with contextlib.closing(sqlite.connect(uri, uri=True)) as cx:
705 cx.execute(self._sql)
716 with contextlib.closing(sqlite.connect(uri, uri=True)) as cx:
718 cx.execute(self._sql)
733 with contextlib.closing(sqlite.connect(database=":memory:")) as cx:
734 self.assertEqual(type(cx), sqlite.Connection)
739 self.cx = sqlite.connect(":memory:")
740 self.cu = self.cx.cursor()
749 self.cx.close()
871 with cx_limit(self.cx, category=category, limit=1):
960 self.cx.commit()
967 self.assertLess(2, self.cx.total_changes, msg='total changes reported wrong value')
1032 cur = self.cx.cursor()
1084 self.assertEqual(self.cu.connection, self.cx)
1089 cur = self.cx.cursor(f)
1146 cursors = [self.cx.execute("select 1") for _ in range(3)]
1153 self.cx = sqlite.connect(":memory:")
1154 self.cx.execute("create table test(b blob)")
1156 self.cx.execute("insert into test(b) values (?)", (self.data,))
1157 self.blob = self.cx.blobopen("test", "b", 1)
1161 self.cx.close()
1220 self.cx.execute("update test set b='aaaa' where rowid=1")
1227 row = self.cx.execute("select b from test").fetchone()
1234 row = self.cx.execute("select b from test").fetchone()
1253 self.cx.execute("update test set b='aaaa' where rowid=1")
1258 ro_blob = self.cx.blobopen("test", "b", 1, readonly=True)
1274 self.cx.blobopen(*args, **kwds)
1289 actual = self.cx.execute("select b from test").fetchone()[0]
1331 actual = self.cx.execute("select b from test").fetchone()[0]
1340 actual = self.cx.execute("select b from test").fetchone()[0]
1363 self.cx.execute("update test set b='aaaa' where rowid=1")
1408 with self.cx.blobopen("test", "b", 1) as blob:
1410 actual = self.cx.execute("select b from test").fetchone()[0]
1421 with self.cx.blobopen("test", "b", 1) as blob:
1426 with memory_database() as cx:
1427 cx.execute("create table test(b blob)")
1428 cx.execute("insert into test values (zeroblob(100))")
1429 blob = cx.blobopen("test", "b", 1)
1455 with memory_database() as cx:
1456 cx.execute("create table test(b blob)")
1457 cx.execute("insert into test(b) values (zeroblob(100))")
1458 blob = cx.blobopen("test", "b", 1)
1459 cx.close()
1466 with memory_database() as cx:
1468 cx.execute("create table t(t blob)")
1469 cx.execute("insert into t(rowid, t) values (?, zeroblob(1))", (rowid,))
1470 cx.blobopen('t', 't', rowid)
1628 with memory_database() as cx, cx_limit(cx) as lim:
1629 cx.executescript("select 'almost too large'".ljust(lim))
1631 cx.executescript("select 'too large'".ljust(lim+1))
1753 self.cx = sqlite.connect(":memory:")
1754 self.cu = self.cx.cursor()
1763 self.cx.close()
1766 self.cx.isolation_level = None # autocommit mode
1767 self.cu = self.cx.cursor()
1775 self.cx.commit()
1783 self.cx.isolation_level = None # autocommit mode
1784 self.cu = self.cx.cursor()
1791 self.cx.commit()
1853 cx = sqlite3.connect("{TESTFN}", timeout={self.CONNECTION_TIMEOUT})
1854 cx.create_function("wait", 0, wait)
1855 with cx:
1856 cx.execute("create table t(t)")
1859 cx.executescript('''
1872 cx.close()
1888 cx = sqlite.connect(TESTFN, timeout=self.CONNECTION_TIMEOUT)
1890 with cx:
1891 cx.execute("insert into t values('test')")
1897 cx.close()