95 """ Create a MassiveObject store, with the following attributes: |
95 """ Create a MassiveObject store, with the following attributes: |
96 |
96 |
97 - cnx: CubicWeb cnx |
97 - cnx: CubicWeb cnx |
98 """ |
98 """ |
99 super(MassiveObjectStore, self).__init__(cnx) |
99 super(MassiveObjectStore, self).__init__(cnx) |
100 self.logger = logging.getLogger('dataio.relationmixin') |
100 self.logger = logging.getLogger('dataimport.massive_store') |
101 self._cnx = cnx |
101 self._cnx = cnx |
102 self.sql = cnx.system_sql |
102 self.sql = cnx.system_sql |
103 self._data_uri_relations = defaultdict(list) |
103 self._data_uri_relations = defaultdict(list) |
104 self._initialized = {'init_uri_eid': set(), |
104 self._initialized = {'init_uri_eid': set(), |
105 'uri_eid_inserted': set(), |
105 'uri_eid_inserted': set(), |
106 'uri_rtypes': set(), |
106 'uri_rtypes': set(), |
107 'entities': set(), |
107 'entities': set(), |
108 'rtypes': set(), |
108 'rtypes': set(), |
109 } |
109 } |
110 self.sql = self._cnx.system_sql |
110 self.sql = self._cnx.system_sql |
111 self.logger = logging.getLogger('dataio.massiveimport') |
|
112 self.slave_mode = slave_mode |
111 self.slave_mode = slave_mode |
113 self.size_constraints = get_size_constraints(cnx.vreg.schema) |
112 self.size_constraints = get_size_constraints(cnx.vreg.schema) |
114 self.default_values = get_default_values(cnx.vreg.schema) |
113 self.default_values = get_default_values(cnx.vreg.schema) |
115 pg_schema = cnx.repo.config.system_source_config.get('db-namespace', 'public') |
114 pg_schema = cnx.repo.config.system_source_config.get('db-namespace', 'public') |
116 self._dbh = PGHelper(self._cnx, pg_schema) |
115 self._dbh = PGHelper(self._cnx, pg_schema) |