views_ajax.py 文件源码

def getDbsFromClusterName(request):
    if request.is_ajax():
        cluster_name = request.POST.get("cluster_name")
    else:
        cluster_name = request.POST['cluster_name']

    # cursor = connection.cursor()
    # cursor.execute("select distinct table_schema from dbconfig_mysql_cluster_metadata where cluster_name=%s", (cluster_name,))
    # dbs = [db[0] for db in cursor.fetchall()]
    # cursor.close()

    dictConn = getSlaveConnStr(cluster_name)
    if not dictConn:
        dictConn = getMasterConnStr(cluster_name)
    Host = dictConn['Host']
    Port = dictConn['Port']
    User = dictConn['User']
    Password = dictConn['Password']
    dbs = getMySQLClusterDbs(Host, Port, User, Password)

    result = {'status':0, 'msg':'ok', 'data':dbs}
    return HttpResponse(json.dumps(result), content_type='application/json')