Anschluss von IBM AS400-server, die für die Datenbank-Operationen hängt

Den README für ibm_db_sa nur Listen DB2 für Linux/Unix/Windows in die "Unterstützte Datenbank" Abschnitt. So ist es wahrscheinlich nicht für DB2 für i, zumindest nicht direkt aus der box.

Da Sie erklärt habe, Sie haben IBM System i Access für Windows empfehle ich nur mit einem der Treiber, die mit ihm kommt (ODBC, OLEDB, oder ADO.NET wie @Charles erwähnt).

Ich persönlich habe immer die ODBC verwenden, entweder pyodbc oder pypyodbc. Entweder man funktioniert gut. Ein einfaches Beispiel:

import pyodbc

connection = pyodbc.connect(
    driver='{iSeries Access ODBC Driver}',
    system='11.22.33.44',
    uid='username',
    pwd='password')
c1 = connection.cursor()

c1.execute('select * from qsys2.sysschemas')
for row in c1:
    print row

Nun, SQLAlchemy Verbindung von Methoden ist pyodbc, so würde ich denken, dass, wenn Sie eine Verbindung mit pyodbc Volltreffer, kann man das irgendwie konfigurieren, SQLAlchemy, das gleiche zu tun. Aber ich bin nicht ein SQLAlchemy-Nutzer selbst, so habe ich nicht den Beispiel-code für die.

UPDATE

Schaffte ich es, SQLAlchemy, um eine Verbindung zu den IBM-i-und ausführen gerade SQL-Abfragen. In anderen Worten, um es über die gleichen Funktionen wie die einfache Verwendung von PyODBC direkt. Ich noch nicht getestet, alle anderen SQLAlchemy bietet. Was ich getan habe, die Verbindung auf meinem Windows 7-Maschine:

• Installieren ibm_db_sa als SQLAlchemy Dialekt
  
  Sie können in der Lage sein zu verwenden pip für diese, aber ich habe es getan die low-tech-Weg:

  1. Download ibm_db_sa von PyPI.
     
     Wie dies Schreibe, die aktuelle version ist version 0.3.2, hochgeladen auf 2014-10-20. Es ist denkbar, dass spätere Versionen werden entweder behoben werden oder gebrochen in verschiedenen Arten (so in der Zukunft, die änderungen, die ich bin, zu beschreiben, möglicherweise nicht erforderlich, oder Sie können nicht arbeiten).
  2. Entpacken Sie das Archiv (ibm_db_sa-0.3.2.tar.gz) und kopieren Sie die beiliegenden ibm_db_sa - Verzeichnis in das sqlalchemy\dialects Verzeichnis.

• Ändern sqlalchemy\dialects\ibm_db_sa\pyodbc.py

  • Fügen Sie die initialize() Methode, um die AS400Dialect_pyodbc Klasse
    
    Der Punkt von diesem ist das überschreiben der Methode mit dem gleichen Namen in DB2Dialect, die AS400Dialect_pyodbc erbt von. Das problem ist, dass DB2Dialect.initialize() versucht, zum festlegen der Attribute dbms_ver und dbms_name, welche nicht verfügbar oder relevant, wenn eine Verbindung zu IBM i mit PyODBC (soweit ich das sagen kann).
  • Hinzufügen von Modul-level-name dialect und legen Sie es auf die AS400Dialect_pyodbc Klasse

Code für die oben genannten änderungen gehen sollte am Ende der Datei, und sehen so aus:

    def initialize(self, connection):
        super(DB2Dialect, self).initialize(connection)

dialect = AS400Dialect_pyodbc

Beachten Sie die Einkerbung! Denken Sie daran, die initialize() Methode muss gehören zu den AS400Dialect_pyodbc Klasse, und dialect muss global sein, um das Modul.

Schließlich, Sie brauchen, um zu geben den Motor Schöpfer das Recht URL:

'ibm_db_sa+pyodbc://username:password@host/*lokale'

(Offensichtlich ist, ersetzen Sie gültige Werte für username, password, und host.)

Das ist es. An diesem Punkt sollten Sie in der Lage zu schaffen, die engine, eine Verbindung zu dem ich, und ausführen plain SQL über SQLAlchemy. Ich würde denken, eine Menge von der ORM-Zeug sollte auch an diesem Punkt, aber ich haben nicht überprüft.

Hier ist ein Beispiel für die Arbeit mit as400, sqlalchemy und pandas.
Diese exammple nehmen eine Reihe von csv-Dateien und einfügen mit pandas/sqlalchemy.
Funktioniert nur für windows, bei linux wird der i-Reihe odbc-Treiber segfaults (Centos 7 und Debian 9 x68_64)

Client ist Windows 10.

Meine as400 version 7.3

Python ist 2.7.14

installiert mit pip: pandas, pyodbc, imb_db_sa, sqlalchemy

Müssen Sie zum installieren von i access für windows aus der ftp://public.dhe.ibm.com/as400/products/clientaccess/win32/v7r1m0/servicepack/si66062/

Nachholen, die änderung @JohnY auf pyodbc.py
C:\Python27\Lib\site-packages\sqlalchemy\dialects\ibm_db_sa\pyodbc.py
Ändern Sie Zeile 99 zu

    pyodbc_driver_name = "IBM i Access ODBC Driver"

Den odbc-Treiber umbenannt.

#!/usr/bin/env python
# -*- coding: utf-8 -*-
import pandas as pd
import numpy as np
from sqlalchemy import create_engine
import glob

csvfiles=(glob.glob("c:/Users/nahum/Documents/OUT/*.csv"))
df_csvfiles = pd.DataFrame(csvfiles)
for index, row in df_csvfiles.iterrows():
    datastore2=pd.read_csv(str(row[0]), delimiter=',', header=[0],skipfooter=3)
    engine = create_engine('ibm_db_sa+pyodbc://DB2_USER:PASSWORD@IP_SERVER/*local')
    datastore2.to_sql('table', engine, schema='SCHEMA', chunksize=1000, if_exists='append', index=False)

Hoffe, es hilft.