Aa8329Hc

1myConnection = mysql.connector.connect(user=username, passwd=password,host=hostname,port=portname,client_flags=[ClientFlag.LOCAL_FILES])
2    myCursor =myConnection.cursor()
3    rootDir = "/share/Festplatte/Saqib/pc72/SK/E17"
4
5    root = pathlib.Path(rootDir)
6
7    non_empty_dirs = {str(p.parent) for p in root.rglob('*') if p.is_file()}
8
9    for f in non_empty_dirs:
10            dB = f.replace('/','_') or f.replace('-','_')
11            dropDB ='DROP DATABASE if exists %s' %dB
12            myCursor.execute(dropDB)
13            myConnection.commit()
14            for dirName, subdirList, fileList in os.walk(rootDir):
15                    if dirName == f:
16                            createDB='CREATE DATABASE %s' %dB
17                            myCursor.execute(createDB)
18                            useDB='use %s' %dB
19                            myCursor.execute(useDB)
20                            myConnection.commit()
21                            for fname in fileList:
22                                    tblname = os.path.basename(fname).split('.')[0]
23
24                                    sql= 'CREATE TABLE %s (Datum varchar(50), Uhrzeit varchar(13), UpsACT_V varchar(6), UpsPRE_V varchar(6), IpsACT_A varchar(6), IpsPRE_A varchar(6), PpsACT_W var$
25                                    myCursor.execute(sql)
26                                    myConnection.commit()
27                                    test = 'The Table %s ' %tblname+' in database %s '%dB+'is created!!'
28
29
30                                    loadData= "LOAD DATA LOCAL INFILE  '%s' "  %fname + "INTO TABLE %s" %tblname
31
32                                    print('The table created in database %s' %dB + ' is %s' %tblname +'.')
33                                    myCursor.execute(loadData)
34                                    myConnection.commit()
35
36    print('program exiting') 
37     
38Traceback (most recent call last):
39  File "29nonEmptyDirTable.py", line 61, in <module>
40    myCursor.execute(loadData)
41  File "/usr/local/lib/python3.5/dist-packages/mysql/connector/cursor.py", line 515, in execute
42    self._handle_result(self._connection.cmd_query(stmt))
43  File "/usr/local/lib/python3.5/dist-packages/mysql/connector/connection.py", line 684, in cmd_query
44    result = self._handle_result(self._send_cmd(ServerCmd.QUERY, query))
45  File "/usr/local/lib/python3.5/dist-packages/mysql/connector/connection.py", line 598, in _handle_result
46    return self._handle_load_data_infile(packet[5:])
47  File "/usr/local/lib/python3.5/dist-packages/mysql/connector/connection.py", line 574, in _handle_load_data_infile
48    filename))
49mysql.connector.errors.InterfaceError: File 'b'CM_entlad_01Nov2018_12Uhr51.txt'' could not be read.