Version 1

[yaffs-website] / web / modules / contrib / migrate_plus / migrate_example / src / Plugin / migrate / source / BeerComment.php

diff --git a/web/modules/contrib/migrate_plus/migrate_example/src/Plugin/migrate/source/BeerComment.php b/web/modules/contrib/migrate_plus/migrate_example/src/Plugin/migrate/source/BeerComment.php
new file mode 100644 (file)
index 0000000..217fad2
--- /dev/null
+++ b/web/modules/contrib/migrate_plus/migrate_example/src/Plugin/migrate/source/BeerComment.php
@@ -0,0 +1,56 @@
+<?php
+
+namespace Drupal\migrate_example\Plugin\migrate\source;
+
+use Drupal\migrate\Plugin\migrate\source\SqlBase;
+
+/**
+ * Source plugin for beer comments.
+ *
+ * @MigrateSource(
+ *   id = "beer_comment"
+ * )
+ */
+class BeerComment extends SqlBase {
+
+  /**
+   * {@inheritdoc}
+   */
+  public function query() {
+    $query = $this->select('migrate_example_beer_comment', 'mec')
+                 ->fields('mec', ['cid', 'cid_parent', 'name', 'mail', 'aid',
+                   'body', 'bid', 'subject'])
+                 ->orderBy('cid_parent', 'ASC');
+    return $query;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function fields() {
+    $fields = [
+      'cid' => $this->t('Comment ID'),
+      'cid_parent' => $this->t('Parent comment ID in case of comment replies'),
+      'name' => $this->t('Comment name (if anon)'),
+      'mail' => $this->t('Comment email (if anon)'),
+      'aid' => $this->t('Account ID (if any)'),
+      'bid' => $this->t('Beer ID that is being commented upon'),
+      'subject' => $this->t('Comment subject'),
+    ];
+
+    return $fields;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function getIds() {
+    return [
+      'cid' => [
+        'type' => 'integer',
+        'alias' => 'mec',
+      ],
+    ];
+  }
+
+}