Skip to content

Commit 98869d2

Browse files
yorekyorek
committed
first commit
1 parent 4f9a6c6 commit 98869d2

14 files changed

+715
-64
lines changed

‎.gitignore

+6
Original file line numberDiff line numberDiff line change
@@ -348,3 +348,9 @@ MigrationBackup/
348348

349349
# Ionide (cross platform F# VS Code tools) working folder
350350
.ionide/
351+
352+
# Custom Files
353+
env.ps1
354+
env.sh
355+
appsettings.Development.json
356+
.env

‎.vscode/launch.json

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
{
2+
// Use IntelliSense to find out which attributes exist for C# debugging
3+
// Use hover for the description of the existing attributes
4+
// For further information visit https://github.com/OmniSharp/omnisharp-vscode/blob/master/debugger-launchjson.md
5+
"version": "0.2.0",
6+
"configurations": [
7+
{
8+
"name": ".NET Core Launch (web)",
9+
"type": "coreclr",
10+
"request": "launch",
11+
"preLaunchTask": "build",
12+
// If you have changed target frameworks, make sure to update the program path.
13+
"program": "${workspaceFolder}/bin/Debug/netcoreapp3.0/azure-sql-db-sync-ct-api.dll",
14+
"args": [],
15+
"cwd": "${workspaceFolder}",
16+
"stopAtEntry": false,
17+
"env": {
18+
"ASPNETCORE_ENVIRONMENT": "Development"
19+
},
20+
"envFile": "${workspaceFolder}/.env",
21+
"sourceFileMap": {
22+
"/Views": "${workspaceFolder}/Views"
23+
}
24+
},
25+
{
26+
"name": ".NET Core Attach",
27+
"type": "coreclr",
28+
"request": "attach",
29+
"processId": "${command:pickProcess}"
30+
}
31+
]
32+
}

‎.vscode/tasks.json

+42
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
{
2+
"version": "2.0.0",
3+
"tasks": [
4+
{
5+
"label": "build",
6+
"command": "dotnet",
7+
"type": "process",
8+
"args": [
9+
"build",
10+
"${workspaceFolder}/azure-sql-db-sync-ct-api.csproj",
11+
"/property:GenerateFullPaths=true",
12+
"/consoleloggerparameters:NoSummary"
13+
],
14+
"problemMatcher": "$msCompile"
15+
},
16+
{
17+
"label": "publish",
18+
"command": "dotnet",
19+
"type": "process",
20+
"args": [
21+
"publish",
22+
"${workspaceFolder}/azure-sql-db-sync-ct-api.csproj",
23+
"/property:GenerateFullPaths=true",
24+
"/consoleloggerparameters:NoSummary"
25+
],
26+
"problemMatcher": "$msCompile"
27+
},
28+
{
29+
"label": "watch",
30+
"command": "dotnet",
31+
"type": "process",
32+
"args": [
33+
"watch",
34+
"run",
35+
"${workspaceFolder}/azure-sql-db-sync-ct-api.csproj",
36+
"/property:GenerateFullPaths=true",
37+
"/consoleloggerparameters:NoSummary"
38+
],
39+
"problemMatcher": "$msCompile"
40+
}
41+
]
42+
}

‎Controllers/ControllerQuery.cs

+67
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,67 @@
1+
using System;
2+
using System.Collections.Generic;
3+
using System.Linq;
4+
using System.Threading.Tasks;
5+
using Microsoft.AspNetCore.Mvc;
6+
using Microsoft.Extensions.Logging;
7+
using System.Text.Json;
8+
using System.Data;
9+
using Microsoft.Data.SqlClient;
10+
using Dapper;
11+
using Microsoft.Extensions.Configuration;
12+
13+
namespace AzureSamples.AzureSQL.Controllers
14+
{
15+
public class ControllerQuery : ControllerBase
16+
{
17+
protected readonly ILogger<ControllerQuery> _logger;
18+
private readonly IConfiguration _config;
19+
20+
public ControllerQuery(IConfiguration config, ILogger<ControllerQuery> logger)
21+
{
22+
_logger = logger;
23+
_config = config;
24+
}
25+
26+
protected async Task<JsonElement> Query(string verb, Type entity, int? id = null, JsonElement payload = default(JsonElement))
27+
{
28+
JsonDocument result = null;
29+
30+
if (!(new string[] {"get", "put", "patch", "delete"}).Contains(verb.ToLower()))
31+
{
32+
throw new ArgumentException($"verb '{verb}' not supported", nameof(verb));
33+
}
34+
35+
string entityName = entity.Name.Replace("Controller", string.Empty).ToLower();
36+
string procedure = $"web.{verb}_{entityName}";
37+
_logger.LogDebug($"Executing {procedure}");
38+
39+
using(var conn = new SqlConnection(_config.GetConnectionString("DefaultConnection"))) {
40+
DynamicParameters parameters = new DynamicParameters();
41+
42+
if (payload.ValueKind != default(JsonValueKind))
43+
{
44+
var json = JsonSerializer.Serialize(payload);
45+
parameters.Add("Json", json);
46+
}
47+
48+
if (id.HasValue)
49+
parameters.Add("Id", id.Value);
50+
51+
var qr = await conn.ExecuteScalarAsync<string>(
52+
sql: procedure,
53+
param: parameters,
54+
commandType: CommandType.StoredProcedure
55+
);
56+
57+
if (qr != null)
58+
result = JsonDocument.Parse(qr);
59+
};
60+
61+
if (result == null)
62+
result = JsonDocument.Parse("[]");
63+
64+
return result.RootElement;
65+
}
66+
}
67+
}

‎Controllers/TrainingSessionSyncController.cs

+36
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
using System;
2+
using System.Collections.Generic;
3+
using System.Linq;
4+
using System.Threading.Tasks;
5+
using Microsoft.AspNetCore.Mvc;
6+
using Microsoft.Extensions.Logging;
7+
using System.Text.Json;
8+
using Microsoft.Extensions.Configuration;
9+
10+
namespace AzureSamples.AzureSQL.Controllers
11+
{
12+
[ApiController]
13+
[Route("trainingsession/sync")]
14+
public class TrainingSessionSyncController : ControllerQuery
15+
{
16+
public TrainingSessionSyncController(IConfiguration config, ILogger<TrainingSessionSyncController> logger):
17+
base(config, logger) {}
18+
19+
public async Task<JsonElement> Get()
20+
{
21+
var clientId = HttpContext.Request.Headers["ClientId"].FirstOrDefault();
22+
var fromVersion = Int32.Parse(HttpContext.Request.Headers["FromVersion"].FirstOrDefault() ?? "0");
23+
24+
var payload = new {
25+
clientId = clientId,
26+
fromVersion = fromVersion
27+
};
28+
29+
var jp = JsonDocument.Parse(JsonSerializer.Serialize(payload));
30+
31+
this._logger.LogInformation($"clientId {clientId}, fromVersion {fromVersion}");
32+
33+
return await this.Query("get", this.GetType(), payload: jp.RootElement);
34+
}
35+
}
36+
}

‎Program.cs

+26
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
using System;
2+
using System.Collections.Generic;
3+
using System.Linq;
4+
using System.Threading.Tasks;
5+
using Microsoft.AspNetCore.Hosting;
6+
using Microsoft.Extensions.Configuration;
7+
using Microsoft.Extensions.Hosting;
8+
using Microsoft.Extensions.Logging;
9+
10+
namespace AzureSamples.AzureSQL
11+
{
12+
public class Program
13+
{
14+
public static void Main(string[] args)
15+
{
16+
CreateHostBuilder(args).Build().Run();
17+
}
18+
19+
public static IHostBuilder CreateHostBuilder(string[] args) =>
20+
Host.CreateDefaultBuilder(args)
21+
.ConfigureWebHostDefaults(webBuilder =>
22+
{
23+
webBuilder.UseStartup<Startup>();
24+
});
25+
}
26+
}

0 commit comments

Comments
 (0)