oci/zeronet
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Bootstrapper SQL query optimizations

Browse source
This commit is contained in:
shortcutme 2017-08-18 14:46:35 +02:00
parent 2af08c0ba1
commit a27422a0fb
No known key found for this signature in database
GPG key ID: 5B63BAE6CB9613AE
1 changed files with 14 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
plugins/disabled-Bootstrapper/BootstrapperDb.py
View file

@ -50,7 +50,7 @@ class BootstrapperDb(Db):
peer_id INTEGER PRIMARY KEY ASC AUTOINCREMENT NOT NULL UNIQUE, peer_id INTEGER PRIMARY KEY ASC AUTOINCREMENT NOT NULL UNIQUE,
port INTEGER NOT NULL, port INTEGER NOT NULL,
ip4 TEXT, ip4 TEXT,
onion TEXT, onion TEXT UNIQUE,
date_added DATETIME DEFAULT (CURRENT_TIMESTAMP), date_added DATETIME DEFAULT (CURRENT_TIMESTAMP),
date_announced DATETIME DEFAULT (CURRENT_TIMESTAMP) date_announced DATETIME DEFAULT (CURRENT_TIMESTAMP)
); );
@ -92,9 +92,9 @@ class BootstrapperDb(Db):
# Check user # Check user
if onion: if onion:
res = self.execute("SELECT * FROM peer WHERE ? LIMIT 1", {"onion": onion}) res = self.execute("SELECT peer_id FROM peer WHERE ? LIMIT 1", {"onion": onion})
else: else:
res = self.execute("SELECT * FROM peer WHERE ? LIMIT 1", {"ip4": ip4, "port": port}) res = self.execute("SELECT peer_id FROM peer WHERE ? LIMIT 1", {"ip4": ip4, "port": port})
user_row = res.fetchone() user_row = res.fetchone()
now = time.strftime("%Y-%m-%d %H:%M:%S") now = time.strftime("%Y-%m-%d %H:%M:%S")
@ -124,27 +124,31 @@ class BootstrapperDb(Db):
else: else:
return 0 return 0
def peerList(self, hash, ip4=None, onions=[], port=None, limit=30, need_types=["ip4", "onion"]): def peerList(self, hash, ip4=None, onions=[], port=None, limit=30, need_types=["ip4", "onion"], order=True):
hash_peers = {"ip4": [], "onion": []} hash_peers = {"ip4": [], "onion": []}
if limit == 0: if limit == 0:
return hash_peers return hash_peers
hashid = self.getHashId(hash) hashid = self.getHashId(hash)
where = "hash_id = :hashid" if order:
order_sql = "ORDER BY date_announced DESC"
else:
order_sql = ""
where_sql = "hash_id = :hashid"
if onions: if onions:
onions_escaped = ["'%s'" % re.sub("[^a-z0-9,]", "", onion) for onion in onions if type(onion) is str] onions_escaped = ["'%s'" % re.sub("[^a-z0-9,]", "", onion) for onion in onions if type(onion) is str]
where += " AND (onion NOT IN (%s) OR onion IS NULL)" % ",".join(onions_escaped) where_sql += " AND (onion NOT IN (%s) OR onion IS NULL)" % ",".join(onions_escaped)
elif ip4: elif ip4:
where += " AND (NOT (ip4 = :ip4 AND port = :port) OR ip4 IS NULL)" where_sql += " AND (NOT (ip4 = :ip4 AND port = :port) OR ip4 IS NULL)"
query = """ query = """
SELECT ip4, port, onion SELECT ip4, port, onion
FROM peer_to_hash FROM peer_to_hash
LEFT JOIN peer USING (peer_id) LEFT JOIN peer USING (peer_id)
WHERE %s WHERE %s
ORDER BY date_announced DESC %s
LIMIT :limit LIMIT :limit
""" % where """ % (where_sql, order_sql)
res = self.execute(query, {"hashid": hashid, "ip4": ip4, "onions": onions, "port": port, "limit": limit}) res = self.execute(query, {"hashid": hashid, "ip4": ip4, "onions": onions, "port": port, "limit": limit})
for row in res: for row in res: