Added sqlite as a database for the library
This commit is contained in:
parent
3077a09a2d
commit
db402f9659
|
@ -1,4 +0,0 @@
|
||||||
__author__="bjschuma"
|
|
||||||
__date__ ="$Dec 27, 2009 9:40:48 PM$"
|
|
||||||
|
|
||||||
__all__=["scan"]
|
|
|
@ -1,20 +0,0 @@
|
||||||
#! /usr/bin/python
|
|
||||||
|
|
||||||
# To change this template, choose Tools | Templates
|
|
||||||
# and open the template in the editor.
|
|
||||||
|
|
||||||
__author__="bjschuma"
|
|
||||||
__date__ ="$Dec 27, 2009 9:44:30 PM$"
|
|
||||||
|
|
||||||
from bt.file import *
|
|
||||||
|
|
||||||
def scan(dir):
|
|
||||||
write(dir)
|
|
||||||
#files = ls(dir)
|
|
||||||
#for file in files:
|
|
||||||
# path = join(dir,file)
|
|
||||||
# if checkDir(path)==True:
|
|
||||||
# self.scan(path)
|
|
||||||
# else:
|
|
||||||
# write(path,True)
|
|
||||||
# self.files += [path]
|
|
|
@ -16,17 +16,23 @@ opt = []
|
||||||
|
|
||||||
import settings
|
import settings
|
||||||
from bt.message import write
|
from bt.message import write
|
||||||
|
from bt.file import *
|
||||||
import bt.proc
|
import bt.proc
|
||||||
from manager import manager
|
from manager import manager
|
||||||
|
from tools import database
|
||||||
|
|
||||||
from tools import library
|
|
||||||
|
settings.set("ocarina", join(settings.get("user"),".ocarina2") )
|
||||||
|
mkdir(settings.get("ocarina"))
|
||||||
|
bt.proc.setname("Ocarina 2")
|
||||||
|
#from tools import library
|
||||||
|
|
||||||
|
|
||||||
# Called every time the plugin is enabled
|
# Called every time the plugin is enabled
|
||||||
def open():
|
def open():
|
||||||
write("Ocarina has been started",True)
|
write("Ocarina has been started",True)
|
||||||
bt.proc.setname("Ocarina 2")
|
database.init()
|
||||||
|
|
||||||
|
|
||||||
# Called every time the plugin is stopped
|
# Called every time the plugin is stopped
|
||||||
def close():
|
def close():
|
||||||
|
|
|
@ -5,8 +5,8 @@ __date__ ="$Dec 27, 2009 8:07:18 PM$"
|
||||||
|
|
||||||
|
|
||||||
global name, app, type, path, opt
|
global name, app, type, path, opt
|
||||||
name = "test"
|
name = "scan"
|
||||||
app = "scion"
|
app = "ocarina"
|
||||||
type = "core"
|
type = "core"
|
||||||
path = ""
|
path = ""
|
||||||
opt = []
|
opt = []
|
||||||
|
@ -14,7 +14,8 @@ opt = []
|
||||||
from bt.message import write
|
from bt.message import write
|
||||||
from bt.file import *
|
from bt.file import *
|
||||||
|
|
||||||
from library import *
|
#from library import *
|
||||||
|
from tools import database
|
||||||
#from library.scan import scan
|
#from library.scan import scan
|
||||||
|
|
||||||
|
|
||||||
|
@ -37,6 +38,7 @@ def scan(dir):
|
||||||
scan(path)
|
scan(path)
|
||||||
else:
|
else:
|
||||||
write(path,True)
|
write(path,True)
|
||||||
|
database.insert(path)
|
||||||
#self.files += [path]
|
#self.files += [path]
|
||||||
|
|
||||||
|
|
||||||
|
@ -46,4 +48,6 @@ def run(args=None):
|
||||||
return
|
return
|
||||||
space = ' '
|
space = ' '
|
||||||
path = expandPath( space.join(args) )
|
path = expandPath( space.join(args) )
|
||||||
|
#database.open()
|
||||||
scan(path)
|
scan(path)
|
||||||
|
database.close()
|
||||||
|
|
|
@ -0,0 +1,4 @@
|
||||||
|
__author__="bjschuma"
|
||||||
|
__date__ ="$Dec 28, 2009 12:21:59 AM$"
|
||||||
|
|
||||||
|
__all__ = ['database']
|
|
@ -0,0 +1,70 @@
|
||||||
|
# This is a simple test plugin, to make sure everything is working
|
||||||
|
|
||||||
|
__author__="bjschuma"
|
||||||
|
__date__ ="$Dec 27, 2009 9:58:50 PM$"
|
||||||
|
|
||||||
|
|
||||||
|
global name, app, type, path, opt
|
||||||
|
name = "database"
|
||||||
|
app = "ocarina"
|
||||||
|
type = "core"
|
||||||
|
path = ""
|
||||||
|
opt = []
|
||||||
|
|
||||||
|
|
||||||
|
import settings
|
||||||
|
from bt.file import *
|
||||||
|
|
||||||
|
import sqlite3
|
||||||
|
|
||||||
|
#global conn, c
|
||||||
|
#conn = None
|
||||||
|
#c = None
|
||||||
|
global db
|
||||||
|
global conn
|
||||||
|
db = None
|
||||||
|
conn = None
|
||||||
|
|
||||||
|
|
||||||
|
# Collect all information for what to insert
|
||||||
|
# Build into a large statement, then insert
|
||||||
|
# This will speed things up
|
||||||
|
# Reconnect to sqlite at every run, to avoid thread problems
|
||||||
|
|
||||||
|
|
||||||
|
def create():
|
||||||
|
global conn
|
||||||
|
conn.execute("create table files (path text)")
|
||||||
|
|
||||||
|
|
||||||
|
def open():
|
||||||
|
global db, conn
|
||||||
|
conn = sqlite3.connect(db)
|
||||||
|
conn.text_factory = str
|
||||||
|
|
||||||
|
|
||||||
|
def close():
|
||||||
|
global conn
|
||||||
|
conn.commit()
|
||||||
|
conn.close()
|
||||||
|
conn = None
|
||||||
|
|
||||||
|
|
||||||
|
def init():
|
||||||
|
global db
|
||||||
|
db = join(settings.get("ocarina"),"ocarina.db")
|
||||||
|
dbExists = checkPath(db)
|
||||||
|
open()
|
||||||
|
if dbExists == False:
|
||||||
|
create()
|
||||||
|
close()
|
||||||
|
|
||||||
|
|
||||||
|
def insert(file):
|
||||||
|
global conn
|
||||||
|
if conn == None:
|
||||||
|
open()
|
||||||
|
#c = conn.cursor()
|
||||||
|
t = (file,)
|
||||||
|
conn.execute('insert into files values(?)',t)
|
||||||
|
#c.close()
|
Loading…
Reference in New Issue