1
2
3
4
5
6
7
8
9
10
11
12
13 from zephir.backend import config
14 from twisted.enterprise import adbapi
15
17
19 """errback du deffered
20 """
21 try:
22 return 0, str(error.type), error.getErrorMessage()
23 except:
24 return 0,''
25
27 """callback du deffered
28 """
29 if l:
30 return 1,'ok'
31 else:
32 return 0,"no records"
33 raise DBException("No records")
34
39
40 -def db_log(dbpool,id_serveur,date,type_msg,msg):
41 """insère un log dans la base zephir
42 """
43 query = """insert into log_serveur (id_serveur,date,type,message) values (%s,'%s','%s','%s')"""
44 msg = msg.replace("'","\\\'")
45 return dbpool.runOperation(query % (id_serveur,date,type_msg,msg))
46
48 """classe utilitaire pour récupérer diverses données sur un serveur"""
49
51 """initialise l'objet serveur et récupère les infos
52 """
53
54 import psycopg2 as pgsql
55 cx = PgSQL.connect(database=config.DB_NAME,user=config.DB_USER,password=config.DB_PASSWD)
56 cu = cx.cursor()
57 cu.execute("select * from serveurs where id=%s" % id_s)
58 cu.close()
59 cx.close()
60