5 |
# |
# |
6 |
|
|
7 |
import sys |
import sys |
8 |
import os |
#import os |
9 |
import codecs |
import codecs |
10 |
#import getopt |
#import getopt |
11 |
import psycopg2 as dbapi |
import psycopg2 as dbapi |
12 |
import psycopg2.extras as extras |
import psycopg2.extras as extras |
13 |
|
from types import StringTypes |
14 |
|
|
15 |
dbapi.extensions.register_type(dbapi.extensions.UNICODE) |
dbapi.extensions.register_type(dbapi.extensions.UNICODE) |
16 |
|
|
17 |
SEP = "$" |
SEP = "\t" |
18 |
|
|
19 |
DBNAME = "ka_inte00002_db" |
DBNAME = "ka_inte00002_db" |
20 |
HOST = "laodameia" |
HOST = "laodameia" |
46 |
|
|
47 |
BLACK_LIST = set(['id', 'master_id', 'uuid_id', 'bearbeiter_id']) |
BLACK_LIST = set(['id', 'master_id', 'uuid_id', 'bearbeiter_id']) |
48 |
|
|
49 |
def empty(x): |
def strReplace(x): |
50 |
|
if type(x) in StringTypes: |
51 |
|
return x.replace("\r", "").replace("\n", " ").replace(SEP, " ") |
52 |
if x is None: return "" |
if x is None: return "" |
53 |
return x |
return x |
54 |
|
|
61 |
return [a[0] for a in self.columns if a[0] not in BLACK_LIST] |
return [a[0] for a in self.columns if a[0] not in BLACK_LIST] |
62 |
|
|
63 |
def valueFields(self): |
def valueFields(self): |
64 |
return [empty(a[2]) for a in self.columns if a[0] not in BLACK_LIST] |
return [strReplace(a[2]) for a in self.columns if a[0] not in BLACK_LIST] |
65 |
|
|
66 |
def numFields(self): |
def numFields(self): |
67 |
s = 0 |
s = 0 |
163 |
out = Writer(sys.stdout) |
out = Writer(sys.stdout) |
164 |
con, cur = None, None |
con, cur = None, None |
165 |
try: |
try: |
166 |
PASSWORD = raw_input("> ") |
#PASSWORD = raw_input("> ") |
167 |
|
PASSWORD = "" |
168 |
con = dbapi.connect( |
con = dbapi.connect( |
169 |
database = DBNAME, |
database = DBNAME, |
170 |
host = HOST, |
host = HOST, |