Romiko

public virtual NodeReference<TNode> Create<TNode>(
            TNode node,
            IEnumerable<IRelationshipAllowingParticipantNode<TNode>> relationships,
            IEnumerable<IndexEntry> indexEntries)
            where TNode : class
        {
            if (node == null)
                throw new ArgumentNullException("node");

            relationships = relationships ?? Enumerable.Empty<IRelationshipAllowingParticipantNode<TNode>>();

Romiko

void CreateClients(MigrationMessage migrationMessage)
        {
            var agencyUniqueId = migrationMessage.AgencyUniqueId;
            var agency = agencyService.GetAgencyByUniqueId(agencyUniqueId);

            if (agency == null)
                throw new ApplicationException("Agency unique id provided for the import process does not match any existing agencies.");

            using (var connection = new SqlCeConnection(connectionString))
            using (var canonicalDb = new ImportDbContext(connection))

Romiko

 NodeReference<Client> TryImportClient(Node<Agency> agency, Clients client, DateTimeOffset timeFirstAttempted)
        {
            NodeReference<Client> reference;

            var callStarted = DateTimeOffset.UtcNow;
            try
            {
                reference = importClientService.ImportClient(client, agency);
            }
            catch (Exception ex)

Romiko

using System;
using MyStory.Logic.Models;
using MyStory.Logic.Models.ImportSchema;
using Neo4jClient;
using Omu.ValueInjecter;

namespace MyStory.Logic.Services.Import
{
    public class ImportClientService : IImportClientService
    {

Romiko

#requires -version 2.0
param (
	[parameter(Mandatory=$true)] [string]$AzureAccountName,
	[parameter(Mandatory=$true)] [string]$AzureServiceName,
	[parameter(Mandatory=$true)] [string]$AzureDeploymentSlot,
	[parameter(Mandatory=$true)] [string]$AzureAccountKey,
	[parameter(Mandatory=$true)] [string]$AzureSubscriptionId,
	[parameter(Mandatory=$true)] [string]$AzureCertificateThumbprint,
	[parameter(Mandatory=$true)] [string]$PackageSource,
	[parameter(Mandatory=$true)] [string]$ConfigSource,

Romiko

@echo off
setlocal
set tempscript=%temp%\%~n0.%random%.ps1
echo $ErrorActionPreference="Stop" >"%tempscript%"
echo ^& "%~dpn0.ps1" %* >>"%tempscript%"
powershell.exe -command "& \"%tempscript%\""
set errlvl=%ERRORLEVEL%
del "%tempscript%"
exit /b %errlvl%

Romiko

#requires -version 2.0
param (
	[parameter(Mandatory=$true)] [string]$AzurePackagePath,
	[parameter(Mandatory=$true)] [string]$AzureSdkRootPath,
	[parameter(Mandatory=$true)] [int]$RetryCountForPolling
)

$ErrorActionPreference = "Stop"

$csrun="$AzureSdkRootPath\bin\csrun.exe"

Romiko

<?xml version="1.0" encoding="utf-8"?>
<Project ToolsVersion="4.0" DefaultTargets="Build" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
  <PropertyGroup>

....all sorts of config stuff

    <Reference Include="System.Data.SqlServerCe, Version=4.0.0.0, Culture=neutral, PublicKeyToken=89845dcd8080cc91, processorArchitecture=MSIL">
      <Private>True</Private>
      <HintPath>..\packages\SqlServerCompact.4.0.8482.1\lib\System.Data.SqlServerCe.dll</HintPath>
    </Reference>

Romiko

;--EndBatch
;--EndBatch
CREATE TABLE [Clients](
	[ExternalSystemName] [nvarchar](50) NOT NULL,
	[ExternalSystemId] [nvarchar](50) NOT NULL,
	[GivenName] [nvarchar](100) NOT NULL,
	[MiddleNames] [nvarchar](200) NULL,
	[FamilyName] [nvarchar](100) NOT NULL,
	[PreferredName] [nvarchar](100) NULL,
	[Gender] [nvarchar](10) NULL,

Romiko

void CreateClients(MigrationMessage migrationMessage)
        {
            var agencyUniqueId = migrationMessage.AgencyUniqueId;
            var agency = agencyService.GetAgencyByUniqueId(agencyUniqueId);

            if (agency == null)
                throw new ApplicationException("Agency unique id provided for the import process does not match any existing agencies.");

            using (var connection = new SqlCeConnection(connectionString))
            using (var canonicalDb = new ImportDbContext(connection))