ninjahini/ninsocket.py at main · ScriptHUBofficial/ninjahini · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
import socket
from threading import Thread
import pymysql
import time

def client_handler(conn):
    db = pymysql.connect(host='localhost',
                         user='root',
                         password='',
                         db='101m',)
    baglanti = db.cursor()

    try:
        while True:

            data = conn.recv(1024).decode("utf-8")
            print(data)
            if not data:
                print("server is down")
                break


            data_list = data.split('|')


            query = "SELECT * FROM `101m` WHERE "
            where_clauses = []

            if len(data_list[0]) != 0:
                where_clauses.append(f"`ADI` LIKE '{data_list[0]}'")
            if len(data_list[1]) != 0:
                where_clauses.append(f"`SOYADI` LIKE '{data_list[1]}'")
            if len(data_list[2]) != 0:
                where_clauses.append(f"`DOGUMTARIHI` LIKE '{data_list[2]}'")
            if len(data_list[3]) != 0:
                where_clauses.append(f"`NUSUFIL` LIKE '{data_list[3]}'")
            if len(data_list[4]) != 0:
                where_clauses.append(f"`TC` LIKE '{data_list[4]}'")

            if len(where_clauses) > 0:
                query += " AND ".join(where_clauses)
                baglanti.execute(query)
                kullanicilar = baglanti.fetchall()
            else:
                kullanicilar = []

            for i in kullanicilar:
                time.sleep(0.1)
                i = list(i)
                i[0] = str(i[0])
                bilgi = '|'.join(i)
                print(bilgi)
                conn.send(bilgi.encode("utf-8"))


        conn.close()

    except ( ConnectionAbortedError,ConnectionResetError ):
        pass


def server_program():
    host = "127.0.0.1"
    port = 5000

    server_socket = socket.socket()
    server_socket.bind((host, port))

    server_socket.listen(2)

    while True:
        conn, address = server_socket.accept()
        print("BAGLANTİ: " + str(address))


        Thread(target=client_handler, args=(conn,) ).start()


if __name__ == '__main__':
    #Thread(target=server_program,daemon=True).start()
    server_program()