1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
from django.db import connection
from postgresqleu.util.db import exec_to_scalar
class InlineEncodedStorage(object):
def __init__(self, key):
self.key = key
def read(self, name):
curs = connection.cursor()
curs.execute("SELECT encode(hashval, 'hex'), data FROM util_storage WHERE key=%(key)s AND storageid=%(id)s", {
'key': self.key, 'id': name})
rows = curs.fetchall()
if len(rows) != 1:
return None, None
return rows[0][0], bytes(rows[0][1])
def save(self, name, content):
content.seek(0)
curs = connection.cursor()
params = {
'key': self.key,
'id': name,
'data': content.read(),
}
curs.execute("UPDATE util_storage SET data=%(data)s WHERE key=%(key)s AND storageid=%(id)s", params)
if curs.rowcount == 0:
curs.execute("INSERT INTO util_storage (key, storageid, data) VALUES (%(key)s, %(id)s, %(data)s)", params)
return name
def get_tag(self, name):
return exec_to_scalar("SELECT encode(hashval, 'hex') FROM util_storage WHERE key=%(key)s AND storageid=%(id)s", {
'key': self.key,
'id': name,
})
def inlineencoded_upload_path(instance, filename):
# Needs to exist for old migrations, but *NOT* in use
return None
|
