db_utils.py
View Options

	# Copyright (C) 2015-2018 The Software Heritage developers
	# See the AUTHORS file at the top-level directory of this distribution
	#
	# This code has been imported from psycopg2, version 2.7.4,
	# https://github.com/psycopg/psycopg2/tree/5afb2ce803debea9533e293eef73c92ffce95bcd
	# and modified by Software Heritage.
	#
	# Original file: lib/extras.py
	#
	# psycopg2 is free software: you can redistribute it and/or modify it under the
	# terms of the GNU Lesser General Public License as published by the Free
	# Software Foundation, either version 3 of the License, or (at your option) any
	# later version.


	import re

	import psycopg2.extensions


	def _paginate(seq, page_size):
	"""Consume an iterable and return it in chunks.
	Every chunk is at most `page_size`. Never return an empty chunk.
	"""
	page = []
	it = iter(seq)
	while 1:
	try:
	for i in range(page_size):
	page.append(next(it))
	yield page
	page = []
	except StopIteration:
	if page:
	yield page
	return


	def _split_sql(sql):
	"""Split sql on a single ``%s`` placeholder.
	Split on the %s, perform %% replacement and return pre, post lists of
	snippets.
	"""
	curr = pre = []
	post = []
	tokens = re.split(br'(%.)', sql)
	for token in tokens:
	if len(token) != 2 or token[:1] != b'%':
	curr.append(token)
	continue

	if token[1:] == b's':
	if curr is pre:
	curr = post
	else:
	raise ValueError(
	"the query contains more than one '%s' placeholder")
	elif token[1:] == b'%':
	curr.append(b'%')
	else:
	raise ValueError("unsupported format character: '%s'"
	% token[1:].decode('ascii', 'replace'))

	if curr is pre:
	raise ValueError("the query doesn't contain any '%s' placeholder")

	return pre, post


	def execute_values_generator(cur, sql, argslist, template=None, page_size=100):
	'''Execute a statement using :sql:`VALUES` with a sequence of parameters.
	Rows returned by the query are returned through a generator.
	You need to consume the generator for the queries to be executed!
	:param cur: the cursor to use to execute the query.
	:param sql: the query to execute. It must contain a single ``%s``
	placeholder, which will be replaced by a `VALUES list`__.
	Example: ``"INSERT INTO mytable (id, f1, f2) VALUES %s"``.
	:param argslist: sequence of sequences or dictionaries with the arguments
	to send to the query. The type and content must be consistent with
	template.
	:param template: the snippet to merge to every item in argslist to
	compose the query.
	- If the argslist items are sequences it should contain positional
	placeholders (e.g. ``"(%s, %s, %s)"``, or ``"(%s, %s, 42)``" if there
	are constants value...).
	- If the argslist items are mappings it should contain named
	placeholders (e.g. ``"(%(id)s, %(f1)s, 42)"``).
	If not specified, assume the arguments are sequence and use a simple
	positional template (i.e. ``(%s, %s, ...)``), with the number of
	placeholders sniffed by the first element in argslist.
	:param page_size: maximum number of argslist items to include in every
	statement. If there are more items the function will execute more than
	one statement.
	:param yield_from_cur: Whether to yield results from the cursor in this
	function directly.
	.. __: https://www.postgresql.org/docs/current/static/queries-values.html
	After the execution of the function the `cursor.rowcount` property will
	not contain a total result.
	'''
	# we can't just use sql % vals because vals is bytes: if sql is bytes
	# there will be some decoding error because of stupid codec used, and Py3
	# doesn't implement % on bytes.
	if not isinstance(sql, bytes):
	sql = sql.encode(
	psycopg2.extensions.encodings[cur.connection.encoding]
	)
	pre, post = _split_sql(sql)

	for page in _paginate(argslist, page_size=page_size):
	if template is None:
	template = b'(' + b','.join([b'%s'] * len(page[0])) + b')'
	parts = pre[:]
	for args in page:
	parts.append(cur.mogrify(template, args))
	parts.append(b',')
	parts[-1:] = post
	cur.execute(b''.join(parts))
	yield from cur

File Metadata

Mime Type: text/x-python
Expires: Fri, Jul 4, 1:30 PM (5 d, 5 h ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3241410

db_utils.py
No OneTemporary
Actions

db_utils.py
View Options

File Metadata

Event Timeline

db_utils.pyNo OneTemporaryActions

db_utils.pyView Options

File Metadata

Event Timeline

db_utils.py
No OneTemporary
Actions

db_utils.py
View Options