Commit: cd03cc05fb9118749950d6374aae11ccc12fea61 - beets-playersync (hg)

Commit MetaInfo

• Revisão: cd03cc05fb9118749950d6374aae11ccc12fea61 (tree)
• Hora: 2017-12-26 20:53:57
• Autor: Jaime Marquínez Ferrándiz <jaime.marquinez.ferrandiz@fast...>
• Commiter: Jaime Marquínez Ferrándiz

Mensagem de Log

Reduce the number of transactions

Mudança Sumário

• modified: beetsplug/playersync.py

Diff

diff -r 0704aeb551aa -r cd03cc05fb91 beetsplug/playersync.py
--- a/beetsplug/playersync.py	Tue Dec 26 12:49:35 2017 +0100
+++ b/beetsplug/playersync.py	Tue Dec 26 12:53:57 2017 +0100
@@ -63,27 +63,27 @@
             db.execute('DELETE FROM playlistsong')
 
         for query in config['queries'].get(list):
-            self.info('Processing query: "{0}"', query)
-            items = lib.items(query)
-            for item in items:
-                self.add_item(lib, db, item)
             with db:
+                self.info('Processing query: "{0}"', query)
+                items = lib.items(query)
+                for item in items:
+                    self.add_item(lib, db, item)
                 db.execute('INSERT INTO query (query) VALUES (?)', (query,))
                 query_id = db.execute('SELECT idQuery FROM query WHERE query=?', (query,)).fetchone()[0]
                 db.executemany('INSERT INTO querysong VALUES (?, ?)', [(query_id, item['id']) for item in items])
 
         for playlist in config['playlists'].get(list):
-            self.info('Processing playlist: "{0}"', playlist)
-            playlist_file = os.path.expanduser(playlist)
-            with open(playlist_file, 'rt') as f:
-                paths = [line for line in (line.strip() for line in f) if line and not line.startswith('#')]
-            items = []
-            for song_path in paths:
-                query, q_sort = parse_query_parts(['path:' + song_path], Item)
-                item = list(lib.items(OrQuery(query)))[0]
-                self.add_item(lib, db, item)
-                items.append(item)
             with db:
+                self.info('Processing playlist: "{0}"', playlist)
+                playlist_file = os.path.expanduser(playlist)
+                with open(playlist_file, 'rt') as f:
+                    paths = [line for line in (line.strip() for line in f) if line and not line.startswith('#')]
+                items = []
+                for song_path in paths:
+                    query, q_sort = parse_query_parts(['path:' + song_path], Item)
+                    item = list(lib.items(OrQuery(query)))[0]
+                    self.add_item(lib, db, item)
+                    items.append(item)
                 db.execute(
                     'INSERT INTO playlist (playlist) VALUES (?)',
                     (playlist,))
@@ -146,5 +146,4 @@
         if IS_PY3 and isinstance(copy_path, bytes):
             copy_path = copy_path.decode()
         if not db.execute('SELECT * FROM song WHERE idSong=?', (item_id,)).fetchall():
-            with db:
-                db.execute('INSERT INTO song (idSong, filename) VALUES (?,?)', (item_id, copy_path))
+            db.execute('INSERT INTO song (idSong, filename) VALUES (?,?)', (item_id, copy_path))