Skip to content

Commit

Permalink
Add examples for query service
Browse files Browse the repository at this point in the history
  • Loading branch information
@XmasApple
XmasApple committed Nov 7, 2023
1 parent 7c8fb70 commit 77c6d37
Show file tree
Hide file tree
Showing 9 changed files with 548 additions and 150 deletions.
5 changes: 3 additions & 2 deletions examples/src/BasicExample/BasicExample.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -4,15 +4,16 @@
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>net6.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings>
<Nullable>enable</Nullable>
<AssemblyName>Ydb.Sdk.Examples.BasicExample</AssemblyName>
<RootNamespace>Ydb.Sdk.Examples</RootNamespace>
</PropertyGroup>

<PropertyGroup>
<RepositoryType>git</RepositoryType>
<RepositoryUrl>https://github.com/ydb-platform/ydb-dotnet-examples</RepositoryUrl>
<PackageProjectUrl>https://github.com/ydb-platform/ydb-dotnet-examples</PackageProjectUrl>
<RepositoryUrl>https://github.com/ydb-platform/ydb-dotnet-sdk</RepositoryUrl>
<PackageProjectUrl>https://github.com/ydb-platform/ydb-dotnet-sdk</PackageProjectUrl>
<Company>YANDEX LLC</Company>
</PropertyGroup>

Expand Down
143 changes: 1 addition & 142 deletions examples/src/BasicExample/FillData.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -50,152 +50,11 @@ REPLACE INTO episodes
return await session.ExecuteDataQuery(
query: query,
txControl: TxControl.BeginSerializableRW().Commit(),
parameters: GetDataParams(),
parameters: DataUtils.GetDataParams(),
settings: DefaultDataQuerySettings
);
});

response.Status.EnsureSuccess();
}

internal record Series(int SeriesId, string Title, DateTime ReleaseDate, string Info);

internal record Season(int SeriesId, int SeasonId, string Title, DateTime FirstAired, DateTime LastAired);

internal record Episode(int SeriesId, int SeasonId, int EpisodeId, string Title, DateTime AirDate);

private static Dictionary<string, YdbValue> GetDataParams()
{
var series = new Series[]
{
new(SeriesId: 1, Title: "IT Crowd", ReleaseDate: DateTime.Parse("2006-02-03"),
Info: "The IT Crowd is a British sitcom produced by Channel 4, written by Graham Linehan, " +
"produced by Ash Atalla and starring Chris O'Dowd, Richard Ayoade, Katherine Parkinson, " +
"and Matt Berry."),
new(SeriesId: 2, Title: "Silicon Valley", ReleaseDate: DateTime.Parse("2014-04-06"),
Info: "Silicon Valley is an American comedy television series created by Mike Judge, " +
"John Altschuler and Dave Krinsky. The series focuses on five young men who founded " +
"a startup company in Silicon Valley.")
};

var seasons = new Season[]
{
new(1, 1, "Season 1", DateTime.Parse("2006-02-03"), DateTime.Parse("2006-03-03")),
new(1, 2, "Season 2", DateTime.Parse("2007-08-24"), DateTime.Parse("2007-09-28")),
new(1, 3, "Season 3", DateTime.Parse("2008-11-21"), DateTime.Parse("2008-12-26")),
new(1, 4, "Season 4", DateTime.Parse("2010-06-25"), DateTime.Parse("2010-07-30")),
new(2, 1, "Season 1", DateTime.Parse("2014-04-06"), DateTime.Parse("2014-06-01")),
new(2, 2, "Season 2", DateTime.Parse("2015-04-12"), DateTime.Parse("2015-06-14")),
new(2, 3, "Season 3", DateTime.Parse("2016-04-24"), DateTime.Parse("2016-06-26")),
new(2, 4, "Season 4", DateTime.Parse("2017-04-23"), DateTime.Parse("2017-06-25")),
new(2, 5, "Season 5", DateTime.Parse("2018-03-25"), DateTime.Parse("2018-05-13")),
};

var episodes = new Episode[]
{
new(1, 1, 1, "Yesterday's Jam", DateTime.Parse("2006-02-03")),
new(1, 1, 2, "Calamity Jen", DateTime.Parse("2006-02-03")),
new(1, 1, 3, "Fifty-Fifty", DateTime.Parse("2006-02-10")),
new(1, 1, 4, "The Red Door", DateTime.Parse("2006-02-17")),
new(1, 1, 5, "The Haunting of Bill Crouse", DateTime.Parse("2006-02-24")),
new(1, 1, 6, "Aunt Irma Visits", DateTime.Parse("2006-03-03")),
new(1, 2, 1, "The Work Outing", DateTime.Parse("2006-08-24")),
new(1, 2, 2, "Return of the Golden Child", DateTime.Parse("2007-08-31")),
new(1, 2, 3, "Moss and the German", DateTime.Parse("2007-09-07")),
new(1, 2, 4, "The Dinner Party", DateTime.Parse("2007-09-14")),
new(1, 2, 5, "Smoke and Mirrors", DateTime.Parse("2007-09-21")),
new(1, 2, 6, "Men Without Women", DateTime.Parse("2007-09-28")),
new(1, 3, 1, "From Hell", DateTime.Parse("2008-11-21")),
new(1, 3, 2, "Are We Not Men?", DateTime.Parse("2008-11-28")),
new(1, 3, 3, "Tramps Like Us", DateTime.Parse("2008-12-05")),
new(1, 3, 4, "The Speech", DateTime.Parse("2008-12-12")),
new(1, 3, 5, "Friendface", DateTime.Parse("2008-12-19")),
new(1, 3, 6, "Calendar Geeks", DateTime.Parse("2008-12-26")),
new(1, 4, 1, "Jen The Fredo", DateTime.Parse("2010-06-25")),
new(1, 4, 2, "The Final Countdown", DateTime.Parse("2010-07-02")),
new(1, 4, 3, "Something Happened", DateTime.Parse("2010-07-09")),
new(1, 4, 4, "Italian For Beginners", DateTime.Parse("2010-07-16")),
new(1, 4, 5, "Bad Boys", DateTime.Parse("2010-07-23")),
new(1, 4, 6, "Reynholm vs Reynholm", DateTime.Parse("2010-07-30")),
new(2, 1, 1, "Minimum Viable Product", DateTime.Parse("2014-04-06")),
new(2, 1, 2, "The Cap Table", DateTime.Parse("2014-04-13")),
new(2, 1, 3, "Articles of Incorporation", DateTime.Parse("2014-04-20")),
new(2, 1, 4, "Fiduciary Duties", DateTime.Parse("2014-04-27")),
new(2, 1, 5, "Signaling Risk", DateTime.Parse("2014-05-04")),
new(2, 1, 6, "Third Party Insourcing", DateTime.Parse("2014-05-11")),
new(2, 1, 7, "Proof of Concept", DateTime.Parse("2014-05-18")),
new(2, 1, 8, "Optimal Tip-to-Tip Efficiency", DateTime.Parse("2014-06-01")),
new(2, 2, 1, "Sand Hill Shuffle", DateTime.Parse("2015-04-12")),
new(2, 2, 2, "Runaway Devaluation", DateTime.Parse("2015-04-19")),
new(2, 2, 3, "Bad Money", DateTime.Parse("2015-04-26")),
new(2, 2, 4, "The Lady", DateTime.Parse("2015-05-03")),
new(2, 2, 5, "Server Space", DateTime.Parse("2015-05-10")),
new(2, 2, 6, "Homicide", DateTime.Parse("2015-05-17")),
new(2, 2, 7, "Adult Content", DateTime.Parse("2015-05-24")),
new(2, 2, 8, "White Hat/Black Hat", DateTime.Parse("2015-05-31")),
new(2, 2, 9, "Binding Arbitration", DateTime.Parse("2015-06-07")),
new(2, 2, 10, "Two Days of the Condor", DateTime.Parse("2015-06-14")),
new(2, 3, 1, "Founder Friendly", DateTime.Parse("2016-04-24")),
new(2, 3, 2, "Two in the Box", DateTime.Parse("2016-05-01")),
new(2, 3, 3, "Meinertzhagen's Haversack", DateTime.Parse("2016-05-08")),
new(2, 3, 4, "Maleant Data Systems Solutions", DateTime.Parse("2016-05-15")),
new(2, 3, 5, "The Empty Chair", DateTime.Parse("2016-05-22")),
new(2, 3, 6, "Bachmanity Insanity", DateTime.Parse("2016-05-29")),
new(2, 3, 7, "To Build a Better Beta", DateTime.Parse("2016-06-05")),
new(2, 3, 8, "Bachman's Earnings Over-Ride", DateTime.Parse("2016-06-12")),
new(2, 3, 9, "Daily Active Users", DateTime.Parse("2016-06-19")),
new(2, 3, 10, "The Uptick", DateTime.Parse("2016-06-26")),
new(2, 4, 1, "Success Failure", DateTime.Parse("2017-04-23")),
new(2, 4, 2, "Terms of Service", DateTime.Parse("2017-04-30")),
new(2, 4, 3, "Intellectual Property", DateTime.Parse("2017-05-07")),
new(2, 4, 4, "Teambuilding Exercise", DateTime.Parse("2017-05-14")),
new(2, 4, 5, "The Blood Boy", DateTime.Parse("2017-05-21")),
new(2, 4, 6, "Customer Service", DateTime.Parse("2017-05-28")),
new(2, 4, 7, "The Patent Troll", DateTime.Parse("2017-06-04")),
new(2, 4, 8, "The Keenan Vortex", DateTime.Parse("2017-06-11")),
new(2, 4, 9, "Hooli-Con", DateTime.Parse("2017-06-18")),
new(2, 4, 10, "Server Error", DateTime.Parse("2017-06-25")),
new(2, 5, 1, "Grow Fast or Die Slow", DateTime.Parse("2018-03-25")),
new(2, 5, 2, "Reorientation", DateTime.Parse("2018-04-01")),
new(2, 5, 3, "Chief Operating Officer", DateTime.Parse("2018-04-08")),
new(2, 5, 4, "Tech Evangelist", DateTime.Parse("2018-04-15")),
new(2, 5, 5, "Facial Recognition", DateTime.Parse("2018-04-22")),
new(2, 5, 6, "Artificial Emotional Intelligence", DateTime.Parse("2018-04-29")),
new(2, 5, 7, "Initial Coin Offering", DateTime.Parse("2018-05-06")),
new(2, 5, 8, "Fifty-One Percent", DateTime.Parse("2018-05-13")),
};

var seriesData = series.Select(s => YdbValue.MakeStruct(new Dictionary<string, YdbValue>
{
{ "series_id", YdbValue.MakeUint64((ulong)s.SeriesId) },
{ "title", YdbValue.MakeUtf8(s.Title) },
{ "series_info", YdbValue.MakeUtf8(s.Info) },
{ "release_date", YdbValue.MakeDate(s.ReleaseDate) }
})).ToList();

var seasonsData = seasons.Select(s => YdbValue.MakeStruct(new Dictionary<string, YdbValue>
{
{ "series_id", YdbValue.MakeUint64((ulong)s.SeriesId) },
{ "season_id", YdbValue.MakeUint64((ulong)s.SeasonId) },
{ "title", YdbValue.MakeUtf8(s.Title) },
{ "first_aired", YdbValue.MakeDate(s.FirstAired) },
{ "last_aired", YdbValue.MakeDate(s.LastAired) }
})).ToList();

var episodesData = episodes.Select(e => YdbValue.MakeStruct(new Dictionary<string, YdbValue>
{
{ "series_id", YdbValue.MakeUint64((ulong)e.SeriesId) },
{ "season_id", YdbValue.MakeUint64((ulong)e.SeasonId) },
{ "episode_id", YdbValue.MakeUint64((ulong)e.EpisodeId) },
{ "title", YdbValue.MakeUtf8(e.Title) },
{ "air_date", YdbValue.MakeDate(e.AirDate) }
})).ToList();

return new Dictionary<string, YdbValue>
{
{ "$seriesData", YdbValue.MakeList(seriesData) },
{ "$seasonsData", YdbValue.MakeList(seasonsData) },
{ "$episodesData", YdbValue.MakeList(episodesData) }
};
}
}
9 changes: 6 additions & 3 deletions examples/src/Common/Common.csproj
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,15 +9,18 @@

<PropertyGroup>
<RepositoryType>git</RepositoryType>
<RepositoryUrl>https://github.com/ydb-platform/ydb-dotnet-examples</RepositoryUrl>
<PackageProjectUrl>https://github.com/ydb-platform/ydb-dotnet-examples</PackageProjectUrl>
<RepositoryUrl>https://github.com/ydb-platform/ydb-dotnet-sdk</RepositoryUrl>
<PackageProjectUrl>https://github.com/ydb-platform/ydb-dotnet-sdk</PackageProjectUrl>
<Company>YANDEX LLC</Company>
</PropertyGroup>

<ItemGroup>
<PackageReference Include="Microsoft.Extensions.Logging" Version="5.0.0" />
<PackageReference Include="Ydb.Sdk" Version="0.1.3" />
<PackageReference Include="Ydb.Sdk.Yc.Auth" Version="0.0.5" />
</ItemGroup>

<ItemGroup>
<ProjectReference Include="..\..\..\src\Ydb.Sdk\src\Ydb.Sdk.csproj" />
</ItemGroup>

</Project>
Loading

0 comments on commit 77c6d37

Please sign in to comment.