Эффективные пользовательские временные шкалы в приложении PHP с Neo4j

• Сначала мы сопоставляем нашего пользователя.
• Затем мы сопоставляем путь между этим пользователем, другими пользователями, за которыми он следует, и их последним потоком (см. Здесь, как Cypher действительно выразителен в том, что вы хотите получить).
• Мы заказываем каналы по их отметке времени.
• Мы возвращаем фиды в коллекции, содержащие автора и фид.
• Мы ограничиваем результат до 20 каналов.

Добавьте ссылку на шаблон профиля пользователя сразу после ссылки на ленту пользователей:

 <p><a href="{{ path('user_timeline', {user_login: user.property('login') }) }}">Show timeline</a></p> 

И создайте шаблон временной шкалы:

 % extends "layout.html.twig" %} {% block content %} <h1>Timeline for {{ user.property('login') }}</h1> {% for friendFeed in timeline %} <div class="row"> <h4>{{ friendFeed.post.title }}</h4> <div>{{ friendFeed.post.body }}</div> <p>Written by: {{ friendFeed.friend.login }} on {{ friendFeed.post.timestamp | date('Ymd H:i:s') }}</p> </div> <hr/> {% endfor %} {% endblock %} 

Теперь у нас есть довольно крутая временная шкала, показывающая последние 20 каналов людей, за которыми вы следите, которые эффективны для базы данных.

Добавление поста во временную шкалу

Чтобы добавить сообщения в связанные списки, запрос Cypher немного сложнее . Вам нужно создать почтовый узел, удалить отношение LAST_POST от пользователя к старому последнему посту, создать новое отношение между самым последним почтовым узлом и пользователем и, наконец, создать отношение PREVIOUS_POST между новым и старым последними почтовыми узлами.

Просто не так ли? Пошли!

Как обычно, мы создадим POST-маршрут для формы, указывающей на действие WebController:

 $app->post('/new_post', 'Ikwattro\\SocialNetwork\\Controller\\WebController::newPost') ->bind('new_post'); 

Далее мы добавим базовую HTML-форму для вставки заголовка и текста сообщения в шаблон пользователя:

 #show_user.html.twig <div class="row"> <div class="col-sm-6"> <h5>Add a user status</h5> <form id="new_post" method="POST" action="{{ path('new_post') }}"> <div class="form-group"> <label for="form_post_title">Post title:</label> <input type="text" minLength="3" name="post_title" id="form_post_title" class="form-control"/> </div> <div class="form-group"> <label for="form_post_body">Post text:</label> <textarea name="post_body" class="form-control"></textarea> </div> <input type="hidden" name="user_login" value="{{ user.property('login') }}"/> <button type="submit" class="btn btn-success">Submit</button> </form> </div> </div> 

И, наконец, мы создаем наше действие newPost :

 public function newPost(Application $application, Request $request) { $title = $request->get('post_title'); $body = $request->get('post_body'); $login = $request->get('user_login'); $query = 'MATCH (user:User) WHERE user.login = {user_login} OPTIONAL MATCH (user)-[r:LAST_POST]->(oldPost) DELETE r CREATE (p:Post) SET p.title = {post_title}, p.body = {post_body} CREATE (user)-[:LAST_POST]->(p) WITH p, collect(oldPost) as oldLatestPosts FOREACH (x in oldLatestPosts|CREATE (p)-[:PREVIOUS_POST]->(x)) RETURN p'; $params = [ 'user_login' => $login, 'post_title' => $title, 'post_body' => $body ]; $result = $application['neo']->sendCypherQuery($query, $params)->getResult(); if (null !== $result->getSingle('p')) { $redirectRoute = $application['url_generator']->generate('user_post', array('user_login' => $login)); return $application->redirect($redirectRoute); } $application->abort(500, sprintf('There was a problem inserting a new post for user "%s"', $login)); } 

Некоторые объяснения:

• Сначала мы сопоставляем пользователя, а затем необязательно сопоставляем его узел LAST_POST .
• Мы удаляем отношения между пользователем и его последним последним постом.
• Мы создаем наш новый пост (который фактически является его последним постом в реальной жизни).
• Мы создаем отношения между пользователем и его «новым» последним постом.
• Мы разбиваем запрос и передаем пользователю, последний пост и коллекцию его старых latest_posts.
• Затем мы перебираем коллекцию и создаем связь PREVIOUS_POST между новым последним постом и следующим.

Сложность в том, что коллекция oldLatestPosts всегда будет содержать 0 или 1 элемент, что идеально подходит для нашего запроса.

Вывод

В этой статье мы обнаружили метод моделирования под названием «Связанный список», узнали, как реализовать его в социальном приложении и как эффективно извлекать узлы и отношения. Мы также изучили некоторые новые предложения Cypher, такие как SKIP и LIMIT, полезные для нумерации страниц.

В то время как графики реального времени немного сложнее, чем мы видели здесь, я надеюсь, что очевидно, что графические базы данных, такие как Neo4j, действительно являются лучшим выбором для приложений такого типа.