Completed
Push — master ( 46b158...10ce1f )
by
unknown
02:19
created
includes/DumpMetaInformation/SqlDumpMetaInformationRepo.php 1 patch
Spacing   +48 added lines, -48 removed lines patch added patch discarded remove patch
@@ -28,14 +28,14 @@  discard block
 block discarded – undo
28 28
 	 * @return DumpMetaInformation
29 29
 	 * @throws InvalidArgumentException
30 30
 	 */
31
-	public function getWithId( $dumpId ) {
32
-		if ( !is_string( $dumpId ) ) {
33
-			throw new InvalidArgumentException( '$dumpId must be string.' );
31
+	public function getWithId($dumpId) {
32
+		if (!is_string($dumpId)) {
33
+			throw new InvalidArgumentException('$dumpId must be string.');
34 34
 		}
35 35
 
36
-		$dumpMetaInformation = $this->getWithIds( array( $dumpId ) );
36
+		$dumpMetaInformation = $this->getWithIds(array($dumpId));
37 37
 
38
-		return reset( $dumpMetaInformation );
38
+		return reset($dumpMetaInformation);
39 39
 	}
40 40
 
41 41
 	/**
@@ -46,15 +46,15 @@  discard block
 block discarded – undo
46 46
 	 * @return DumpMetaInformation[]
47 47
 	 * @throws InvalidArgumentException
48 48
 	 */
49
-	public function getWithIds( array $dumpIds ) {
50
-		foreach ( $dumpIds as $dumpId ) {
51
-			if ( !is_string( $dumpId ) ) {
52
-				throw new InvalidArgumentException( '$dumpIds must contain only strings.' );
49
+	public function getWithIds(array $dumpIds) {
50
+		foreach ($dumpIds as $dumpId) {
51
+			if (!is_string($dumpId)) {
52
+				throw new InvalidArgumentException('$dumpIds must contain only strings.');
53 53
 			}
54 54
 		}
55 55
 
56
-		if( count( $dumpIds ) > 0 ) {
57
-			$db = wfGetDB( DB_SLAVE );
56
+		if (count($dumpIds) > 0) {
57
+			$db = wfGetDB(DB_SLAVE);
58 58
 			$result = $db->select(
59 59
 				array(
60 60
 					self::META_TABLE_NAME,
@@ -74,7 +74,7 @@  discard block
 block discarded – undo
74 74
 				)
75 75
 			);
76 76
 
77
-			return $this->buildDumpMetaInformationFromResult( $result );
77
+			return $this->buildDumpMetaInformationFromResult($result);
78 78
 		}
79 79
 
80 80
 		return array();
@@ -89,17 +89,17 @@  discard block
 block discarded – undo
89 89
 	 * @throws InvalidArgumentException
90 90
 	 * @return DumpMetaInformation[]
91 91
 	 */
92
-	public function getWithIdentifierProperties( array $identifierPropertyIds ) {
93
-		foreach ( $identifierPropertyIds as $propertyId ) {
94
-			if ( !( $propertyId instanceof PropertyId ) ) {
95
-				throw new InvalidArgumentException( '$identifierProperties must contain only PropertyIds.' );
92
+	public function getWithIdentifierProperties(array $identifierPropertyIds) {
93
+		foreach ($identifierPropertyIds as $propertyId) {
94
+			if (!($propertyId instanceof PropertyId)) {
95
+				throw new InvalidArgumentException('$identifierProperties must contain only PropertyIds.');
96 96
 			}
97 97
 		}
98 98
 
99
-		if( count( $identifierPropertyIds ) > 0 ) {
100
-			$db = wfGetDB( DB_SLAVE );
99
+		if (count($identifierPropertyIds) > 0) {
100
+			$db = wfGetDB(DB_SLAVE);
101 101
 			$identifierPropertyIds = array_map(
102
-				function( PropertyId $id ) {
102
+				function(PropertyId $id) {
103 103
 					return $id->getSerialization();
104 104
 				},
105 105
 				$identifierPropertyIds
@@ -112,13 +112,13 @@  discard block
 block discarded – undo
112 112
 				)
113 113
 			);
114 114
 			$dumpIds = array();
115
-			foreach ( $result as $row ) {
116
-				if ( !in_array( $row->dump_id, $dumpIds ) ) {
115
+			foreach ($result as $row) {
116
+				if (!in_array($row->dump_id, $dumpIds)) {
117 117
 					$dumpIds[] = $row->dump_id;
118 118
 				}
119 119
 			}
120 120
 
121
-			return $this->getWithIds( $dumpIds );
121
+			return $this->getWithIds($dumpIds);
122 122
 		}
123 123
 
124 124
 		return array();
@@ -130,7 +130,7 @@  discard block
 block discarded – undo
130 130
 	 * @return ItemId[]
131 131
 	 */
132 132
 	public function getSourceItemIds() {
133
-		$db = wfGetDB( DB_SLAVE );
133
+		$db = wfGetDB(DB_SLAVE);
134 134
 		$result = $db->selectFieldValues(
135 135
 			self::META_TABLE_NAME,
136 136
 			'source_qid',
@@ -155,7 +155,7 @@  discard block
 block discarded – undo
155 155
 	 * @return DumpMetaInformation[]
156 156
 	 */
157 157
 	public function getAll() {
158
-		$db = wfGetDB( DB_SLAVE );
158
+		$db = wfGetDB(DB_SLAVE);
159 159
 		$result = $db->select(
160 160
 			array(
161 161
 				self::META_TABLE_NAME,
@@ -173,7 +173,7 @@  discard block
 block discarded – undo
173 173
 			)
174 174
 		);
175 175
 
176
-		return $this->buildDumpMetaInformationFromResult( $result );
176
+		return $this->buildDumpMetaInformationFromResult($result);
177 177
 	}
178 178
 
179 179
 	/**
@@ -181,34 +181,34 @@  discard block
 block discarded – undo
181 181
 	 * @return null|array
182 182
 	 * @throws UnexpectedValueException
183 183
 	 */
184
-	private function buildDumpMetaInformationFromResult( ResultWrapper $result ) {
184
+	private function buildDumpMetaInformationFromResult(ResultWrapper $result) {
185 185
 		$aggregatedRows = array();
186
-		foreach ( $result as $row ) {
187
-			if ( array_key_exists( $row->id, $aggregatedRows ) ) {
188
-				$propertyId = new PropertyId( $row->identifier_pid );
186
+		foreach ($result as $row) {
187
+			if (array_key_exists($row->id, $aggregatedRows)) {
188
+				$propertyId = new PropertyId($row->identifier_pid);
189 189
 				$aggregatedRows[$row->id]->identifier_pid[] = $propertyId;
190 190
 			} else {
191
-				if ( $row->identifier_pid !== null ) {
192
-					$propertyId = new PropertyId( $row->identifier_pid );
193
-					$row->identifier_pid = array( $propertyId );
191
+				if ($row->identifier_pid !== null) {
192
+					$propertyId = new PropertyId($row->identifier_pid);
193
+					$row->identifier_pid = array($propertyId);
194 194
 				}
195 195
 				$aggregatedRows[$row->id] = $row;
196 196
 			}
197 197
 		}
198 198
 
199 199
 		$dumpMetaInformation = array();
200
-		foreach ( $aggregatedRows as $row ) {
200
+		foreach ($aggregatedRows as $row) {
201 201
 			$dumpId = $row->id;
202
-			$sourceItemId = new ItemId( $row->source_qid );
203
-			$importDate = wfTimestamp( TS_MW, $row->import_date );
202
+			$sourceItemId = new ItemId($row->source_qid);
203
+			$importDate = wfTimestamp(TS_MW, $row->import_date);
204 204
 			$language = $row->language;
205 205
 			$sourceUrl = $row->source_url;
206 206
 			$size = (int)$row->size;
207
-			$licenseItemId = new ItemId( $row->license_qid );
207
+			$licenseItemId = new ItemId($row->license_qid);
208 208
 			$identifierPropertyIds = $row->identifier_pid;
209 209
 
210 210
 			$dumpMetaInformation[$row->dump_id] =
211
-				new DumpMetaInformation( $dumpId,
211
+				new DumpMetaInformation($dumpId,
212 212
 					$sourceItemId,
213 213
 					$identifierPropertyIds,
214 214
 					$importDate,
@@ -227,22 +227,22 @@  discard block
 block discarded – undo
227 227
 	 *
228 228
 	 * @param DumpMetaInformation $dumpMetaInformation
229 229
 	 */
230
-	public function save( DumpMetaInformation $dumpMetaInformation ) {
231
-		$db = wfGetDB( DB_SLAVE );
230
+	public function save(DumpMetaInformation $dumpMetaInformation) {
231
+		$db = wfGetDB(DB_SLAVE);
232 232
 		$dumpId = $dumpMetaInformation->getDumpId();
233
-		$accumulator = $this->getDumpInformationFields( $db, $dumpMetaInformation );
233
+		$accumulator = $this->getDumpInformationFields($db, $dumpMetaInformation);
234 234
 
235 235
 		$existing = $db->selectRow(
236 236
 			self::META_TABLE_NAME,
237
-			array( 'id' ),
238
-			array( 'id' => $dumpId )
237
+			array('id'),
238
+			array('id' => $dumpId)
239 239
 		);
240 240
 
241
-		if ( $existing ) {
241
+		if ($existing) {
242 242
 			$db->update(
243 243
 				self::META_TABLE_NAME,
244 244
 				$accumulator,
245
-				array( 'id' => $dumpId )
245
+				array('id' => $dumpId)
246 246
 			);
247 247
 		} else {
248 248
 			$db->insert(
@@ -253,12 +253,12 @@  discard block
 block discarded – undo
253 253
 
254 254
 		$db->delete(
255 255
 			self::IDENTIFIER_PROPERTIES_TABLE_NAME,
256
-			array( 'dump_id' => $dumpId )
256
+			array('dump_id' => $dumpId)
257 257
 		);
258 258
 		$db->insert(
259 259
 			self::IDENTIFIER_PROPERTIES_TABLE_NAME,
260 260
 			array_map(
261
-				function ( PropertyId $identifierPropertyId ) use ( $dumpId ) {
261
+				function(PropertyId $identifierPropertyId) use ($dumpId) {
262 262
 					return array(
263 263
 						'dump_id' => $dumpId,
264 264
 						'identifier_pid' => $identifierPropertyId->getSerialization()
@@ -274,11 +274,11 @@  discard block
 block discarded – undo
274 274
 	 * @param DumpMetaInformation $dumpMetaInformation
275 275
 	 * @return array
276 276
 	 */
277
-	private function getDumpInformationFields( Database $db,  DumpMetaInformation $dumpMetaInformation ) {
277
+	private function getDumpInformationFields(Database $db, DumpMetaInformation $dumpMetaInformation) {
278 278
 		return array(
279 279
 			'id' => $dumpMetaInformation->getDumpId(),
280 280
 			'source_qid' => $dumpMetaInformation->getSourceItemId()->getSerialization(),
281
-			'import_date' => $db->timestamp( $dumpMetaInformation->getImportDate() ),
281
+			'import_date' => $db->timestamp($dumpMetaInformation->getImportDate()),
282 282
 			'language' => $dumpMetaInformation->getLanguageCode(),
283 283
 			'source_url' => $dumpMetaInformation->getSourceUrl(),
284 284
 			'size' => $dumpMetaInformation->getSize(),
Please login to merge, or discard this patch.