70 lines
2.3 KiB
Python
70 lines
2.3 KiB
Python
import mysql.connector
|
|
def test():
|
|
cnx = mysql.connector.connect(user='asterisk', password='ESDx]hqxS*z.qHu3', host='10.0.0.10', database='asterisk')
|
|
cursor = cnx.cursor()
|
|
|
|
cursor.execute("select * from ps_aors")
|
|
for row in cursor:
|
|
print(row)
|
|
|
|
sequence = cursor.column_names
|
|
print(sequence)
|
|
|
|
|
|
cnx.close()
|
|
|
|
def create_Endpoint(username, context, password):
|
|
cnx = mysql.connector.connect(user='asterisk', password='ESDx]hqxS*z.qHu3', host='10.0.0.10', database='asterisk')
|
|
cursor = cnx.cursor()
|
|
# endpoint
|
|
query = ("INSERT INTO asterisk.ps_endpoints(id, transport,aors,auth,CONTEXT, disallow, allow) "
|
|
"VALUES(\'"+username+"\', 'transport-udp',\'"+username+"\',\'"+username+"\',\'"+context+"\','all','ulaw')")
|
|
cursor.execute(query )
|
|
print(query)
|
|
# aors
|
|
query = ("INSERT INTO asterisk.ps_aors(id, max_contacts)"
|
|
"VALUES(\'"+username+"\', 2)")
|
|
cursor.execute(query)
|
|
# auths
|
|
query = ("INSERT INTO asterisk.ps_auths(id, auth_type, PASSWORD, username)"
|
|
"VALUES(\'" + username + "\','userpass',\'"+password+"\',\'"+username+"\')")
|
|
|
|
cursor.execute(query)
|
|
cnx.commit()
|
|
cnx.close()
|
|
|
|
def delete_Endpoint(username):
|
|
cnx = mysql.connector.connect(user='asterisk', password='ESDx]hqxS*z.qHu3', host='10.0.0.10', database='asterisk')
|
|
cursor = cnx.cursor()
|
|
# endpoint
|
|
query = ("DELETE FROM asterisk.ps_endpoints WHERE id=\'"+username+"\'")
|
|
cursor.execute(query)
|
|
# aors
|
|
query = ("DELETE FROM asterisk.ps_aors WHERE id=\'"+username+"\'")
|
|
cursor.execute(query)
|
|
# auths
|
|
query = ("DELETE FROM asterisk.ps_auths WHERE id=\'"+username+"\'")
|
|
cursor.execute(query)
|
|
cnx.commit()
|
|
cnx.close()
|
|
|
|
def update_Password(username, password):
|
|
cnx = mysql.connector.connect(user='asterisk', password='ESDx]hqxS*z.qHu3', host='10.0.0.10', database='asterisk')
|
|
cursor = cnx.cursor()
|
|
|
|
query = ("update asterisk.ps_auths set password = \'"+password+"\' where id=\'"+username+"\'")
|
|
cursor.execute(query)
|
|
|
|
cnx.commit()
|
|
cnx.close()
|
|
|
|
def getUsers():
|
|
|
|
cnx = mysql.connector.connect(user='asterisk', password='ESDx]hqxS*z.qHu3', host='10.0.0.10', database='asterisk')
|
|
cursor = cnx.cursor()
|
|
|
|
query = ("select username from asterisk.ps_auths")
|
|
cursor.execute(query)
|
|
# print(cursor.fetchall())
|
|
return cursor.fetchall()
|
|
cnx.close() |