Server socket send query to client in python

from socket import *
from threading import Thread
import time
import psycopg2
import sys

def myquery1():
 con = None

 try:
     
    con = psycopg2.connect(database='mydb', user='myuser') 
    cur = con.cursor()
    cur.execute("SELECT * FROM users")

    while True:
      
        row = cur.fetchone()
        
        if row == None:
            break
            
        qu = row[0], "|", row[1], "|", row[4]
        return (qu)

 except psycopg2.DatabaseError, e:
    qu = 'Error %s' % e   
    return (qu) 
    sys.exit(1)
    
    
 finally:
    
    if con:
        con.close()

def myquery2():
 con = None

 try:
     
    con = psycopg2.connect(database='mydb', user='myuser') 
    cur = con.cursor()
    cur.execute("SELECT * FROM users_list")

    while True:
      
        row = cur.fetchone()
        
        if row == None:
            break
            
        qu = row[0], "|", row[1], "|", row[4]
        return (qu)

 except psycopg2.DatabaseError, e:
    qu = 'Error %s' % e   
    return (qu) 
    sys.exit(1)
    
    
 finally:
    
    if con:
        con.close()

def clientHandler():
    conn, addr = s.accept()
    print addr, "is Connected"

    while True: 
	data = conn.recv(1024)
       	if data == "!Q":
                conn.send("Disconnected")
                break    
	if not data: break 
       	if data == "!Q1":
                conn.send (str(myquery1()))
       	if data == "!Q2":
                conn.send (str(myquery1()))


HOST = ''
PORT = 5000

s = socket(AF_INET, SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(5)
print "Server is running......"

for i in range(5): 
		 Thread(target=clientHandler).start()

s.close()

Select allOpen in new window