equal
deleted
inserted
replaced
24 from time import asctime |
24 from time import asctime |
25 from datetime import date, datetime, time |
25 from datetime import date, datetime, time |
26 from collections import defaultdict |
26 from collections import defaultdict |
27 from base64 import b64encode |
27 from base64 import b64encode |
28 |
28 |
29 from six import string_types, integer_types, text_type, binary_type |
29 from six import (string_types, integer_types, text_type, binary_type, |
|
30 add_metaclass) |
30 from six.moves import cPickle as pickle, range |
31 from six.moves import cPickle as pickle, range |
|
32 |
|
33 from logilab.common.deprecation import class_deprecated |
31 |
34 |
32 from cubicweb.utils import make_uid |
35 from cubicweb.utils import make_uid |
33 from cubicweb.server.sqlutils import SQL_PREFIX |
36 from cubicweb.server.sqlutils import SQL_PREFIX |
34 from cubicweb.dataimport.stores import NoHookRQLObjectStore |
37 from cubicweb.dataimport.stores import NoHookRQLObjectStore |
35 |
38 |
194 formatted_row.append(value) |
197 formatted_row.append(value) |
195 rows.append('\t'.join(formatted_row)) |
198 rows.append('\t'.join(formatted_row)) |
196 return StringIO('\n'.join(rows)) |
199 return StringIO('\n'.join(rows)) |
197 |
200 |
198 |
201 |
|
202 @add_metaclass(class_deprecated) |
199 class SQLGenObjectStore(NoHookRQLObjectStore): |
203 class SQLGenObjectStore(NoHookRQLObjectStore): |
200 """Controller of the data import process. This version is based |
204 """Controller of the data import process. This version is based |
201 on direct insertions throught SQL command (COPY FROM or execute many). |
205 on direct insertions throught SQL command (COPY FROM or execute many). |
202 |
206 |
203 >>> store = SQLGenObjectStore(cnx) |
207 >>> store = SQLGenObjectStore(cnx) |
204 >>> store.create_entity('Person', ...) |
208 >>> store.create_entity('Person', ...) |
205 >>> store.flush() |
209 >>> store.flush() |
206 """ |
210 """ |
|
211 __deprecation_warning__ = '[3.23] this class is deprecated, use MassiveObjectStore instead' |
207 |
212 |
208 def __init__(self, cnx, dump_output_dir=None, nb_threads_statement=1): |
213 def __init__(self, cnx, dump_output_dir=None, nb_threads_statement=1): |
209 """ |
214 """ |
210 Initialize a SQLGenObjectStore. |
215 Initialize a SQLGenObjectStore. |
211 |
216 |