mirror of
https://github.com/valitydev/salt.git
synced 2024-11-08 01:18:58 +00:00
Use more meaningful function names for sqlite3
This commit is contained in:
parent
1e32fea983
commit
6cc3390538
@ -13,6 +13,14 @@ def __virtual__():
|
|||||||
return False
|
return False
|
||||||
return 'sqlite3'
|
return 'sqlite3'
|
||||||
|
|
||||||
|
def _connect(db=None):
|
||||||
|
if db == None:
|
||||||
|
return False
|
||||||
|
|
||||||
|
con = sqlite3.connect(db)
|
||||||
|
cur = con.cursor()
|
||||||
|
return cur
|
||||||
|
|
||||||
def version():
|
def version():
|
||||||
'''
|
'''
|
||||||
Return version of pysqlite
|
Return version of pysqlite
|
||||||
@ -33,35 +41,81 @@ def sqlite_version():
|
|||||||
'''
|
'''
|
||||||
return sqlite3.sqlite_version
|
return sqlite3.sqlite_version
|
||||||
|
|
||||||
def query(db=None, sql=None):
|
def modify(db=None, sql=None):
|
||||||
'''
|
'''
|
||||||
Issue an SQL query to sqlite3 (with no return data)
|
Issue an SQL query to sqlite3 (with no return data), usually used
|
||||||
|
to modify the database in some way (insert, delete, create, etc)
|
||||||
|
|
||||||
CLI Example::
|
CLI Example::
|
||||||
|
|
||||||
salt '*' sqlite3.query /root/test.db 'CREATE TABLE test(id INT, testdata TEXT);'
|
salt '*' sqlite3.modify /root/test.db 'CREATE TABLE test(id INT, testdata TEXT);'
|
||||||
'''
|
'''
|
||||||
if db == None:
|
cur = _connect(db)
|
||||||
|
|
||||||
|
if cur == False:
|
||||||
return False
|
return False
|
||||||
|
|
||||||
con = sqlite3.connect(db)
|
|
||||||
cur = con.cursor()
|
|
||||||
cur.execute(sql)
|
cur.execute(sql)
|
||||||
return True
|
return True
|
||||||
|
|
||||||
def select(db=None, sql=None):
|
def fetch(db=None, sql=None):
|
||||||
'''
|
'''
|
||||||
SELECT data from an sqlite3 db (returns all rows, be careful!)
|
Retrieve data from an sqlite3 db (returns all rows, be careful!)
|
||||||
|
|
||||||
CLI Example::
|
CLI Example::
|
||||||
|
|
||||||
salt '*' sqlite3.select /root/test.db 'SELECT * FROM test;'
|
salt '*' sqlite3.fetch /root/test.db 'SELECT * FROM test;'
|
||||||
'''
|
'''
|
||||||
if db == None:
|
cur = _connect(db)
|
||||||
|
|
||||||
|
if cur == False:
|
||||||
return False
|
return False
|
||||||
|
|
||||||
con = sqlite3.connect(db)
|
|
||||||
cur = con.cursor()
|
|
||||||
cur.execute(sql)
|
cur.execute(sql)
|
||||||
rows = cur.fetchall()
|
rows = cur.fetchall()
|
||||||
return rows
|
return rows
|
||||||
|
|
||||||
|
def tables(db=None):
|
||||||
|
'''
|
||||||
|
Show all tables in the database
|
||||||
|
|
||||||
|
CLI Example::
|
||||||
|
|
||||||
|
salt '*' sqlite3.tables /root/test.db
|
||||||
|
'''
|
||||||
|
cur = _connect(db)
|
||||||
|
|
||||||
|
if cur == False:
|
||||||
|
return False
|
||||||
|
|
||||||
|
cur.execute("SELECT name FROM sqlite_master WHERE type='table' ORDER BY name;")
|
||||||
|
rows = cur.fetchall()
|
||||||
|
return rows
|
||||||
|
|
||||||
|
def indices(db=None):
|
||||||
|
'''
|
||||||
|
Show all indices in the database
|
||||||
|
|
||||||
|
CLI Example::
|
||||||
|
|
||||||
|
salt '*' sqlite3.indices /root/test.db
|
||||||
|
'''
|
||||||
|
cur = _connect(db)
|
||||||
|
|
||||||
|
if cur == False:
|
||||||
|
return False
|
||||||
|
|
||||||
|
cur.execute("SELECT name FROM sqlite_master WHERE type='index' ORDER BY name;")
|
||||||
|
rows = cur.fetchall()
|
||||||
|
return rows
|
||||||
|
|
||||||
|
def indexes(db=None):
|
||||||
|
'''
|
||||||
|
Show all indices in the database, for people with poor spelling skills
|
||||||
|
|
||||||
|
CLI Example::
|
||||||
|
|
||||||
|
salt '*' sqlite3.indexes /root/test.db
|
||||||
|
'''
|
||||||
|
return indices(db)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user