From 352efccfa34e574184dccedd2c58fbda4a70036f Mon Sep 17 00:00:00 2001 From: danilov6083 Date: Sun, 30 Nov 2025 00:47:41 +0300 Subject: [PATCH 1/3] added go example for lesson 3.1 --- dev-1/lesson-3.1/go/Makefile | 4 + dev-1/lesson-3.1/go/go.mod | 19 +++ dev-1/lesson-3.1/go/go.sum | 176 +++++++++++++++++++++++ dev-1/lesson-3.1/go/issue.go | 11 ++ dev-1/lesson-3.1/go/issue_repository.go | 127 ++++++++++++++++ dev-1/lesson-3.1/go/main.go | 61 ++++++++ dev-1/lesson-3.1/go/query_helper.go | 88 ++++++++++++ dev-1/lesson-3.1/go/schema_repository.go | 37 +++++ 8 files changed, 523 insertions(+) create mode 100644 dev-1/lesson-3.1/go/Makefile create mode 100644 dev-1/lesson-3.1/go/go.mod create mode 100644 dev-1/lesson-3.1/go/go.sum create mode 100644 dev-1/lesson-3.1/go/issue.go create mode 100644 dev-1/lesson-3.1/go/issue_repository.go create mode 100644 dev-1/lesson-3.1/go/main.go create mode 100644 dev-1/lesson-3.1/go/query_helper.go create mode 100644 dev-1/lesson-3.1/go/schema_repository.go diff --git a/dev-1/lesson-3.1/go/Makefile b/dev-1/lesson-3.1/go/Makefile new file mode 100644 index 0000000..ad92936 --- /dev/null +++ b/dev-1/lesson-3.1/go/Makefile @@ -0,0 +1,4 @@ + +.PHONY: run +run: + go run main.go diff --git a/dev-1/lesson-3.1/go/go.mod b/dev-1/lesson-3.1/go/go.mod new file mode 100644 index 0000000..2f660c0 --- /dev/null +++ b/dev-1/lesson-3.1/go/go.mod @@ -0,0 +1,19 @@ +module ydb-sample + +go 1.25.3 + +require github.com/ydb-platform/ydb-go-sdk/v3 v3.117.1 + +require ( + github.com/golang-jwt/jwt/v4 v4.5.2 // indirect + github.com/google/uuid v1.6.0 // indirect + github.com/jonboulle/clockwork v0.5.0 // indirect + github.com/ydb-platform/ydb-go-genproto v0.0.0-20250911135631-b3beddd517d9 // indirect + golang.org/x/net v0.46.0 // indirect + golang.org/x/sync v0.17.0 // indirect + golang.org/x/sys v0.37.0 // indirect + golang.org/x/text v0.30.0 // indirect + google.golang.org/genproto/googleapis/rpc v0.0.0-20251014184007-4626949a642f // indirect + google.golang.org/grpc v1.76.0 // indirect + google.golang.org/protobuf v1.36.10 // indirect +) diff --git a/dev-1/lesson-3.1/go/go.sum b/dev-1/lesson-3.1/go/go.sum new file mode 100644 index 0000000..2cccdce --- /dev/null +++ b/dev-1/lesson-3.1/go/go.sum @@ -0,0 +1,176 @@ +cloud.google.com/go v0.26.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= +cloud.google.com/go v0.34.0/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= +github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= +github.com/antihax/optional v1.0.0/go.mod h1:uupD/76wgC+ih3iEmQUL+0Ugr19nfwCT1kdvxnR2qWY= +github.com/census-instrumentation/opencensus-proto v0.2.1/go.mod h1:f6KPmirojxKA12rnyqOA5BBL4O983OfeGPqjHWSTneU= +github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs= +github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw= +github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc= +github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk= +github.com/cncf/udpa/go v0.0.0-20210930031921-04548b0d99d4/go.mod h1:6pvJx4me5XPnfI9Z40ddWsdw2W/uZgQLFXToKeRcDiI= +github.com/cncf/xds/go v0.0.0-20210922020428-25de7278fc84/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20211001041855-01bcc9b48dfe/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/cncf/xds/go v0.0.0-20211011173535-cb28da3451f1/go.mod h1:eXthEFrGJvWHgFFCl3hGmgk+/aYT6PnTQLykKQRLhEs= +github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/envoyproxy/go-control-plane v0.9.0/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= +github.com/envoyproxy/go-control-plane v0.9.1-0.20191026205805-5f8ba28d4473/go.mod h1:YTl/9mNaCwkRvm6d1a2C3ymFceY/DCBVvsKhRF0iEA4= +github.com/envoyproxy/go-control-plane v0.9.4/go.mod h1:6rpuAdCZL397s3pYoYcLgu1mIlRU8Am5FuJP05cCM98= +github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk= +github.com/envoyproxy/go-control-plane v0.10.2-0.20220325020618-49ff273808a1/go.mod h1:KJwIaB5Mv44NWtYuAOFCVOjcI94vtpEz2JU/D2v6IjE= +github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c= +github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04= +github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI= +github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY= +github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= +github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= +github.com/golang-jwt/jwt/v4 v4.5.2 h1:YtQM7lnr8iZ+j5q71MGKkNw9Mn7AjHM68uc9g5fXeUI= +github.com/golang-jwt/jwt/v4 v4.5.2/go.mod h1:m21LjoU+eqJr34lmDMbreY2eSTRJ1cv77w39/MY0Ch0= +github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= +github.com/golang/mock v1.1.1/go.mod h1:oTYuIxOrZwtPieC+H1uAHpcLFnEyAGVDL/k47Jfbm0A= +github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= +github.com/golang/protobuf v1.3.2/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= +github.com/golang/protobuf v1.3.3/go.mod h1:vzj43D7+SQXF/4pzW/hwtAqwc6iTitCiVSaWz5lYuqw= +github.com/golang/protobuf v1.4.0-rc.1/go.mod h1:ceaxUfeHdC40wWswd/P6IGgMaK3YpKi5j83Wpe3EHw8= +github.com/golang/protobuf v1.4.0-rc.1.0.20200221234624-67d41d38c208/go.mod h1:xKAWHe0F5eneWXFV3EuXVDTCmh+JuBKY0li0aMyXATA= +github.com/golang/protobuf v1.4.0-rc.2/go.mod h1:LlEzMj4AhA7rCAGe4KMBDvJI+AwstrUpVNzEA03Pprs= +github.com/golang/protobuf v1.4.0-rc.4.0.20200313231945-b860323f09d0/go.mod h1:WU3c8KckQ9AFe+yFwt9sWVRKCVIyN9cPHBJSNnbL67w= +github.com/golang/protobuf v1.4.0/go.mod h1:jodUvKwWbYaEsadDk5Fwe5c77LiNKVO9IDvqG2KuDX0= +github.com/golang/protobuf v1.4.1/go.mod h1:U8fpvMrcmy5pZrNK1lt4xCsGvpyWQ/VVv6QDs8UjoX8= +github.com/golang/protobuf v1.4.2/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= +github.com/golang/protobuf v1.4.3/go.mod h1:oDoupMAO8OvCJWAcko0GGGIgR6R6ocIYbsSw735rRwI= +github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk= +github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY= +github.com/golang/protobuf v1.5.4 h1:i7eJL8qZTpSEXOPTxNKhASYpMn+8e5Q6AdndVa1dWek= +github.com/golang/protobuf v1.5.4/go.mod h1:lnTiLA8Wa4RWRcIUkrtSVa5nRhsEGBg48fD6rSs7xps= +github.com/google/go-cmp v0.2.0/go.mod h1:oXzfMopK8JAjlY9xF4vHSVASa0yLyX7SntLO5aqRK0M= +github.com/google/go-cmp v0.3.0/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= +github.com/google/go-cmp v0.3.1/go.mod h1:8QqcDgzrUqlUb/G2PQTWiueGozuR1884gddMywk6iLU= +github.com/google/go-cmp v0.4.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.5.0/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE= +github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8= +github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU= +github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= +github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= +github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw= +github.com/jonboulle/clockwork v0.5.0 h1:Hyh9A8u51kptdkR+cqRpT1EebBwTn1oK9YfGYbdFz6I= +github.com/jonboulle/clockwork v0.5.0/go.mod h1:3mZlmanh0g2NDKO5TWZVJAfofYk64M7XN3SzBPjZF60= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA= +github.com/rekby/fixenv v0.6.1 h1:jUFiSPpajT4WY2cYuc++7Y1zWrnCxnovGCIX72PZniM= +github.com/rekby/fixenv v0.6.1/go.mod h1:/b5LRc06BYJtslRtHKxsPWFT/ySpHV+rWvzTg+XWk4c= +github.com/rogpeppe/fastuuid v1.2.0/go.mod h1:jVj6XXZzXRy/MSR5jhDC/2q6DgLz+nrA6LYCDYWNEvQ= +github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= +github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= +github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= +github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA= +github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= +github.com/ydb-platform/ydb-go-genproto v0.0.0-20250911135631-b3beddd517d9 h1:SKqSRP6/ocY2Z4twOqKEKxpmawVTHTvQiom7hrU6jt0= +github.com/ydb-platform/ydb-go-genproto v0.0.0-20250911135631-b3beddd517d9/go.mod h1:Er+FePu1dNUieD+XTMDduGpQuCPssK5Q4BjF+IIXJ3I= +github.com/ydb-platform/ydb-go-sdk/v3 v3.117.1 h1:SgYE74T+fo40xvJszWhK8IGS5GNjLcbYPzYL+6wsLGw= +github.com/ydb-platform/ydb-go-sdk/v3 v3.117.1/go.mod h1:IgDKkfYE4FyJilTRe2BTtaurb2EWdMIsQbO02UW3wKM= +go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA= +go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A= +go.opentelemetry.io/otel v1.37.0 h1:9zhNfelUvx0KBfu/gb+ZgeAfAgtWrfHJZcAqFC228wQ= +go.opentelemetry.io/otel v1.37.0/go.mod h1:ehE/umFRLnuLa/vSccNq9oS1ErUlkkK71gMcN34UG8I= +go.opentelemetry.io/otel/metric v1.37.0 h1:mvwbQS5m0tbmqML4NqK+e3aDiO02vsf/WgbsdpcPoZE= +go.opentelemetry.io/otel/metric v1.37.0/go.mod h1:04wGrZurHYKOc+RKeye86GwKiTb9FKm1WHtO+4EVr2E= +go.opentelemetry.io/otel/sdk v1.37.0 h1:ItB0QUqnjesGRvNcmAcU0LyvkVyGJ2xftD29bWdDvKI= +go.opentelemetry.io/otel/sdk v1.37.0/go.mod h1:VredYzxUvuo2q3WRcDnKDjbdvmO0sCzOvVAiY+yUkAg= +go.opentelemetry.io/otel/sdk/metric v1.37.0 h1:90lI228XrB9jCMuSdA0673aubgRobVZFhbjxHHspCPc= +go.opentelemetry.io/otel/sdk/metric v1.37.0/go.mod h1:cNen4ZWfiD37l5NhS+Keb5RXVWZWpRE+9WyVCpbo5ps= +go.opentelemetry.io/otel/trace v1.37.0 h1:HLdcFNbRQBE2imdSEgm/kwqmQj1Or1l/7bW6mxVK7z4= +go.opentelemetry.io/otel/trace v1.37.0/go.mod h1:TlgrlQ+PtQO5XFerSPUYG0JSgGyryXewPGyayAWSBS0= +go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI= +go.uber.org/mock v0.4.0 h1:VcM4ZOtdbR4f6VXfiOpwpVJDL6lCReaZ6mw31wqh7KU= +go.uber.org/mock v0.4.0/go.mod h1:a6FSlNadKUHUa9IP5Vyt1zh4fC7uAwxMutEAscFbkZc= +golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= +golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto= +golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA= +golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE= +golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU= +golang.org/x/lint v0.0.0-20190313153728-d0100b6bd8b3/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc= +golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20190108225652-1e06a53dbb7e/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= +golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= +golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg= +golang.org/x/net v0.0.0-20200822124328-c89045814202/go.mod h1:/O7V0waA8r7cgGh81Ro3o1hOxt32SMVPicZroKQ2sZA= +golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU= +golang.org/x/net v0.46.0 h1:giFlY12I07fugqwPuWJi68oOnpfqFnJIJzaIIm2JVV4= +golang.org/x/net v0.46.0/go.mod h1:Q9BGdFy1y4nkUwiLvT5qtyhAnEHgnQ/zd8PfU6nc210= +golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= +golang.org/x/oauth2 v0.0.0-20200107190931-bf48bf16ab8d/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw= +golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20181221193216-37e7f081c4d4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= +golang.org/x/sync v0.17.0 h1:l60nONMj9l5drqw6jlhIELNv9I0A4OFgRsG9k2oT9Ug= +golang.org/x/sync v0.17.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI= +golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= +golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210119212857-b64e53b001e4/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.37.0 h1:fdNQudmxPjkdUTPnLn5mdQv7Zwvbvpaxqs831goi9kQ= +golang.org/x/sys v0.37.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks= +golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= +golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.30.0 h1:yznKA/E9zq54KzlzBEAWn1NXSQ8DIp/NYMy88xJjl4k= +golang.org/x/text v0.30.0/go.mod h1:yDdHFIX9t+tORqspjENWgzaCVXgk0yYnYuSZ8UzzBVM= +golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= +golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY= +golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs= +golang.org/x/tools v0.0.0-20190524140312-2c0ae7006135/go.mod h1:RgjU9mgBXZiqYHBnxXauZ1Gv1EHHAz9KjViQ78xBX0Q= +golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= +gonum.org/v1/gonum v0.16.0 h1:5+ul4Swaf3ESvrOnidPp4GZbzf0mxVQpDCYUQE7OJfk= +gonum.org/v1/gonum v0.16.0/go.mod h1:fef3am4MQ93R2HHpKnLk4/Tbh/s0+wqD5nfa6Pnwy4E= +google.golang.org/appengine v1.1.0/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= +google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4= +google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc= +google.golang.org/genproto v0.0.0-20190819201941-24fa4b261c55/go.mod h1:DMBHOl98Agz4BDEuKkezgsaosCRResVns1a3J2ZsMNc= +google.golang.org/genproto v0.0.0-20200513103714-09dca8ec2884/go.mod h1:55QSHmfGQM9UVYDPBsyGGes0y52j32PQ3BqQfXhyH3c= +google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013/go.mod h1:NbSheEEYHJ7i3ixzK3sjbqSGDJWnxyFXZblF3eUsNvo= +google.golang.org/genproto/googleapis/rpc v0.0.0-20251014184007-4626949a642f h1:1FTH6cpXFsENbPR5Bu8NQddPSaUUE6NA2XdZdDSAJK4= +google.golang.org/genproto/googleapis/rpc v0.0.0-20251014184007-4626949a642f/go.mod h1:7i2o+ce6H/6BluujYR+kqX3GKH+dChPTQU19wjRPiGk= +google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c= +google.golang.org/grpc v1.23.0/go.mod h1:Y5yQAOtifL1yxbo5wqy6BxZv8vAUGQwXBOALyacEbxg= +google.golang.org/grpc v1.25.1/go.mod h1:c3i+UQWmh7LiEpx4sFZnkU36qjEYZ0imhYfXVyQciAY= +google.golang.org/grpc v1.27.0/go.mod h1:qbnxyOmOxrQa7FizSgH+ReBfzJrCY1pSN7KXBS8abTk= +google.golang.org/grpc v1.33.1/go.mod h1:fr5YgcSWrqhRRxogOsw7RzIpsmvOZ6IcH4kBYTpR3n0= +google.golang.org/grpc v1.36.0/go.mod h1:qjiiYl8FncCW8feJPdyg3v6XW24KsRHe+dy9BAGRRjU= +google.golang.org/grpc v1.47.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= +google.golang.org/grpc v1.76.0 h1:UnVkv1+uMLYXoIz6o7chp59WfQUYA2ex/BXQ9rHZu7A= +google.golang.org/grpc v1.76.0/go.mod h1:Ju12QI8M6iQJtbcsV+awF5a4hfJMLi4X0JLo94ULZ6c= +google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= +google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= +google.golang.org/protobuf v0.0.0-20200228230310-ab0ca4ff8a60/go.mod h1:cfTl7dwQJ+fmap5saPgwCLgHXTUD7jkjRqWcaiX5VyM= +google.golang.org/protobuf v1.20.1-0.20200309200217-e05f789c0967/go.mod h1:A+miEFZTKqfCUM6K7xSMQL9OKL/b6hQv+e19PK+JZNE= +google.golang.org/protobuf v1.21.0/go.mod h1:47Nbq4nVaFHyn7ilMalzfO3qCViNmqZ2kzikPIcrTAo= +google.golang.org/protobuf v1.22.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= +google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= +google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU= +google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c= +google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= +google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= +google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc= +google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= +google.golang.org/protobuf v1.36.10 h1:AYd7cD/uASjIL6Q9LiTjz8JLcrh/88q5UObnmY3aOOE= +google.golang.org/protobuf v1.36.10/go.mod h1:HTf+CrKn2C3g5S8VImy6tdcUvCska2kB7j23XfzDpco= +gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v2 v2.2.3/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= +gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= +honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= +honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4= diff --git a/dev-1/lesson-3.1/go/issue.go b/dev-1/lesson-3.1/go/issue.go new file mode 100644 index 0000000..999529b --- /dev/null +++ b/dev-1/lesson-3.1/go/issue.go @@ -0,0 +1,11 @@ +package main + +import ( + "time" +) + +type Issue struct { + Id int64 `sql:"id"` + Title string `sql:"title"` + Timestamp time.Time `sql:"created_at"` +} diff --git a/dev-1/lesson-3.1/go/issue_repository.go b/dev-1/lesson-3.1/go/issue_repository.go new file mode 100644 index 0000000..0ddeb48 --- /dev/null +++ b/dev-1/lesson-3.1/go/issue_repository.go @@ -0,0 +1,127 @@ +package main + +import ( + "context" + "errors" + "math/rand" + "time" + + ydb "github.com/ydb-platform/ydb-go-sdk/v3" + "github.com/ydb-platform/ydb-go-sdk/v3/query" + "github.com/ydb-platform/ydb-go-sdk/v3/sugar" +) + +var ( + random = rand.New( + rand.NewSource(time.Now().UnixNano()), + ) +) + +type IssueRepository struct { + query *QueryHelper +} + +func NewIssueRepository(query *QueryHelper) *IssueRepository { + return &IssueRepository{ + query: query, + } +} + +func (repo *IssueRepository) AddIssue(title string) (*Issue, error) { + id := random.Int63() // do not repeat in production + timestamp := time.Now() + + err := repo.query.ExecuteTx(` + DECLARE $id AS Int64; + DECLARE $title AS Text; + DECLARE $created_at AS Timestamp; + + UPSERT INTO issues (id, title, created_at) + VALUES ($id, $title, $created_at); + `, + query.SerializableReadWriteTxControl(query.CommitTx()), + ydb.ParamsBuilder(). + Param("$id").Int64(id). + Param("$title").Text(title). + Param("$created_at").Timestamp(timestamp). + Build(), + ) + if err != nil { + return nil, err + } + + return &Issue{ + Id: id, + Title: title, + Timestamp: timestamp, + }, nil +} + +func (repo *IssueRepository) FindById(id int64) (*Issue, error) { + result := make([]Issue, 0) + + repo.query.Query(` + SELECT + id, + title, + created_at + FROM issues + WHERE id=$id; + `, + query.SnapshotReadOnlyTxControl(), + ydb.ParamsBuilder(). + Param("$id").Int64(id). + Build(), + func(resultSet query.ResultSet, ctx context.Context) error { + for row, err := range sugar.UnmarshalRows[Issue](resultSet.Rows(ctx)) { + if err != nil { + clear(result) + return err + } + + result = append(result, row) + } + return nil + }, + ) + + if len(result) > 1 { + return nil, errors.New("Multiple rows with the same id") + } + if len(result) == 0 { + return nil, errors.New("Didnt found any issues (lol)") + } + return &result[0], nil +} + +func (repo *IssueRepository) FindAll() ([]Issue, error) { + result := make([]Issue, 0) + + err := repo.query.Query(` + SELECT + id, + title, + created_at + FROM issues; + `, + query.SnapshotReadOnlyTxControl(), + ydb.ParamsBuilder().Build(), + func(resultSet query.ResultSet, ctx context.Context) error { + for row, err := range sugar.UnmarshalRows[Issue](resultSet.Rows(ctx)) { + clear(result) + + if err != nil { + return err + } + + result = append(result, row) + } + return nil + }, + ) + if err != nil { + return result, err + } + + return result, nil +} diff --git a/dev-1/lesson-3.1/go/main.go b/dev-1/lesson-3.1/go/main.go new file mode 100644 index 0000000..1600dd6 --- /dev/null +++ b/dev-1/lesson-3.1/go/main.go @@ -0,0 +1,61 @@ +package main + +import ( + "context" + "log" + "time" + + "github.com/ydb-platform/ydb-go-sdk/v3" +) + +// author: Egor Danilov +func main() { + connectionCtx, cancel := context.WithTimeout(context.Background(), 10*time.Second) + defer cancel() + + dsn := "grpc://localhost:2136/local" + + db, err := ydb.Open(connectionCtx, dsn) + if err != nil { + log.Fatal(err) + } + defer db.Close(connectionCtx) + + queryHelper := NewQueryHelper(db) + + schemaRepository := NewSchemaRepository(queryHelper) + issuesRepository := NewIssueRepository(queryHelper) + + schemaRepository.DropSchema() + schemaRepository.CreateSchema() + + firstIssue, err := issuesRepository.AddIssue("Ticket 1") + if err != nil { + log.Fatalf("Some error happened (1): %v\n", err) + } + + _, err = issuesRepository.AddIssue("Ticket 2") + if err != nil { + log.Fatalf("Some error happened (2): %v\n", err) + } + + _, err = issuesRepository.AddIssue("Ticket 3") + if err != nil { + log.Fatalf("Some error happened (3): %v\n", err) + } + + issues, err := issuesRepository.FindAll() + if err != nil { + log.Fatalf("Some error happened while finding all: %v\n", err) + } + for _, issue := range issues { + log.Printf("Issue: %v\n", issue) + } + + searchFirstIssue, err := issuesRepository.FindById(firstIssue.Id) + if err != nil { + log.Fatal(err) + } else { + log.Printf("First issue: %v\n", searchFirstIssue) + } +} diff --git a/dev-1/lesson-3.1/go/query_helper.go b/dev-1/lesson-3.1/go/query_helper.go new file mode 100644 index 0000000..d380c52 --- /dev/null +++ b/dev-1/lesson-3.1/go/query_helper.go @@ -0,0 +1,88 @@ +package main + +import ( + "context" + "errors" + "io" + + "github.com/ydb-platform/ydb-go-sdk/v3" + "github.com/ydb-platform/ydb-go-sdk/v3/query" +) + +type QueryHelper struct { + driver *ydb.Driver + ctx context.Context +} + +func NewQueryHelper(driver *ydb.Driver) *QueryHelper { + return &QueryHelper{ + driver: driver, + } +} + +func (q *QueryHelper) Execute(yql string) error { + return q.ExecuteTx( + yql, + query.NoTx(), + ydb.ParamsBuilder().Build(), + ) +} + +func (q *QueryHelper) ExecuteTx( + yql string, + txControl *query.TransactionControl, + params ydb.Params, +) error { + return q.driver.Query().Do( + q.ctx, + func(ctx context.Context, s query.Session) error { + err := s.Exec( + ctx, + yql, + query.WithTxControl(txControl), + query.WithParameters(params), + ) + return err + }, + ) +} + +func (q *QueryHelper) Query( + yql string, + txControl *query.TransactionControl, + params ydb.Params, + materializeFunc func(query.ResultSet, context.Context) error, +) error { + return q.driver.Query().Do( + q.ctx, + func(ctx context.Context, s query.Session) error { + result, err := s.Query( + ctx, + yql, + query.WithTxControl(txControl), + query.WithParameters(params), + ) + + if err != nil { + return err + } + + defer func() { _ = result.Close(ctx) }() + + for { + resultSet, err := result.NextResultSet(ctx) + if err != nil { + if errors.Is(err, io.EOF) { + break + } + + return err + } + + materializeFunc(resultSet, q.ctx) + } + + return nil + }, + ) +} diff --git a/dev-1/lesson-3.1/go/schema_repository.go b/dev-1/lesson-3.1/go/schema_repository.go new file mode 100644 index 0000000..82f7d8b --- /dev/null +++ b/dev-1/lesson-3.1/go/schema_repository.go @@ -0,0 +1,37 @@ +package main + +import ( + "log" +) + +type SchemaRepository struct { + query *QueryHelper +} + +func NewSchemaRepository(query *QueryHelper) *SchemaRepository { + return &SchemaRepository{ + query: query, + } +} + +func (repo *SchemaRepository) CreateSchema() { + err := repo.query.Execute(` + CREATE TABLE IF NOT EXISTS issues ( + id Int64 NOT NULL, + title Text NOT NULL, + created_at Timestamp NOT NULL, + PRIMARY KEY (id) + ); + `, + ) + if err != nil { + log.Fatal(err) + } +} + +func (repo *SchemaRepository) DropSchema() { + err := repo.query.Execute("DROP TABLE IF EXISTS issues;") + if err != nil { + log.Fatal(err) + } +} From 85c9c3bec0799b5ea2169118a1007bf08de131d8 Mon Sep 17 00:00:00 2001 From: danilov6083 Date: Mon, 1 Dec 2025 00:50:58 +0300 Subject: [PATCH 2/3] added ctx for queries --- dev-1/lesson-3.1/go/Makefile | 2 +- dev-1/lesson-3.1/go/issue_repository.go | 17 +++++++++-------- dev-1/lesson-3.1/go/main.go | 19 +++++++++++-------- dev-1/lesson-3.1/go/query_helper.go | 12 +++++++----- dev-1/lesson-3.1/go/schema_repository.go | 8 +++++--- 5 files changed, 33 insertions(+), 25 deletions(-) diff --git a/dev-1/lesson-3.1/go/Makefile b/dev-1/lesson-3.1/go/Makefile index ad92936..235eb64 100644 --- a/dev-1/lesson-3.1/go/Makefile +++ b/dev-1/lesson-3.1/go/Makefile @@ -1,4 +1,4 @@ .PHONY: run run: - go run main.go + go run . diff --git a/dev-1/lesson-3.1/go/issue_repository.go b/dev-1/lesson-3.1/go/issue_repository.go index 0ddeb48..29b61cb 100644 --- a/dev-1/lesson-3.1/go/issue_repository.go +++ b/dev-1/lesson-3.1/go/issue_repository.go @@ -27,7 +27,7 @@ func NewIssueRepository(query *QueryHelper) *IssueRepository { } } -func (repo *IssueRepository) AddIssue(title string) (*Issue, error) { +func (repo *IssueRepository) AddIssue(ctx context.Context, title string) (*Issue, error) { id := random.Int63() // do not repeat in production timestamp := time.Now() @@ -39,6 +39,7 @@ func (repo *IssueRepository) AddIssue(title string) (*Issue, error) { UPSERT INTO issues (id, title, created_at) VALUES ($id, $title, $created_at); `, + ctx, query.SerializableReadWriteTxControl(query.CommitTx()), ydb.ParamsBuilder(). Param("$id").Int64(id). @@ -57,7 +58,7 @@ func (repo *IssueRepository) AddIssue(title string) (*Issue, error) { }, nil } -func (repo *IssueRepository) FindById(id int64) (*Issue, error) { +func (repo *IssueRepository) FindById(ctx context.Context, id int64) (*Issue, error) { result := make([]Issue, 0) repo.query.Query(` @@ -68,6 +69,7 @@ func (repo *IssueRepository) FindById(id int64) (*Issue, error) { FROM issues WHERE id=$id; `, + ctx, query.SnapshotReadOnlyTxControl(), ydb.ParamsBuilder(). Param("$id").Int64(id). @@ -84,17 +86,17 @@ func (repo *IssueRepository) FindById(id int64) (*Issue, error) { return nil }, ) - + if len(result) > 1 { return nil, errors.New("Multiple rows with the same id") } if len(result) == 0 { - return nil, errors.New("Didnt found any issues (lol)") + return nil, errors.New("Did not find any issues (lol)") } return &result[0], nil } -func (repo *IssueRepository) FindAll() ([]Issue, error) { +func (repo *IssueRepository) FindAll(ctx context.Context) ([]Issue, error) { result := make([]Issue, 0) err := repo.query.Query(` @@ -104,16 +106,15 @@ func (repo *IssueRepository) FindAll() ([]Issue, error) { created_at FROM issues; `, + ctx, query.SnapshotReadOnlyTxControl(), ydb.ParamsBuilder().Build(), func(resultSet query.ResultSet, ctx context.Context) error { for row, err := range sugar.UnmarshalRows[Issue](resultSet.Rows(ctx)) { - clear(result) - if err != nil { + clear(result) return err } - result = append(result, row) } return nil diff --git a/dev-1/lesson-3.1/go/main.go b/dev-1/lesson-3.1/go/main.go index 1600dd6..95916dc 100644 --- a/dev-1/lesson-3.1/go/main.go +++ b/dev-1/lesson-3.1/go/main.go @@ -26,25 +26,28 @@ func main() { schemaRepository := NewSchemaRepository(queryHelper) issuesRepository := NewIssueRepository(queryHelper) - schemaRepository.DropSchema() - schemaRepository.CreateSchema() + queryCtx, queryCancel := context.WithTimeout(context.Background(), 30*time.Second) + defer queryCancel() - firstIssue, err := issuesRepository.AddIssue("Ticket 1") + schemaRepository.DropSchema(queryCtx) + schemaRepository.CreateSchema(queryCtx) + + firstIssue, err := issuesRepository.AddIssue(queryCtx, "Ticket 1") if err != nil { log.Fatalf("Some error happened (1): %v\n", err) } - _, err = issuesRepository.AddIssue("Ticket 2") + _, err = issuesRepository.AddIssue(queryCtx, "Ticket 2") if err != nil { log.Fatalf("Some error happened (2): %v\n", err) } - _, err = issuesRepository.AddIssue("Ticket 3") + _, err = issuesRepository.AddIssue(queryCtx, "Ticket 3") if err != nil { log.Fatalf("Some error happened (3): %v\n", err) } - issues, err := issuesRepository.FindAll() + issues, err := issuesRepository.FindAll(queryCtx) if err != nil { log.Fatalf("Some error happened while finding all: %v\n", err) } @@ -52,10 +55,10 @@ func main() { log.Printf("Issue: %v\n", issue) } - searchFirstIssue, err := issuesRepository.FindById(firstIssue.Id) + foundFirstIssue, err := issuesRepository.FindById(queryCtx, firstIssue.Id) if err != nil { log.Fatal(err) } else { - log.Printf("First issue: %v\n", searchFirstIssue) + log.Printf("First issue: %v\n", foundFirstIssue) } } diff --git a/dev-1/lesson-3.1/go/query_helper.go b/dev-1/lesson-3.1/go/query_helper.go index d380c52..b88b568 100644 --- a/dev-1/lesson-3.1/go/query_helper.go +++ b/dev-1/lesson-3.1/go/query_helper.go @@ -11,7 +11,6 @@ import ( type QueryHelper struct { driver *ydb.Driver - ctx context.Context } func NewQueryHelper(driver *ydb.Driver) *QueryHelper { @@ -20,9 +19,10 @@ func NewQueryHelper(driver *ydb.Driver) *QueryHelper { } } -func (q *QueryHelper) Execute(yql string) error { +func (q *QueryHelper) Execute(yql string, ctx context.Context) error { return q.ExecuteTx( yql, + ctx, query.NoTx(), ydb.ParamsBuilder().Build(), ) @@ -30,11 +30,12 @@ func (q *QueryHelper) Execute(yql string) error { func (q *QueryHelper) ExecuteTx( yql string, + ctx context.Context, txControl *query.TransactionControl, params ydb.Params, ) error { return q.driver.Query().Do( - q.ctx, + ctx, func(ctx context.Context, s query.Session) error { err := s.Exec( ctx, @@ -49,12 +50,13 @@ func (q *QueryHelper) ExecuteTx( func (q *QueryHelper) Query( yql string, + ctx context.Context, txControl *query.TransactionControl, params ydb.Params, materializeFunc func(query.ResultSet, context.Context) error, ) error { return q.driver.Query().Do( - q.ctx, + ctx, func(ctx context.Context, s query.Session) error { result, err := s.Query( ctx, @@ -79,7 +81,7 @@ func (q *QueryHelper) Query( return err } - materializeFunc(resultSet, q.ctx) + materializeFunc(resultSet, ctx) } return nil diff --git a/dev-1/lesson-3.1/go/schema_repository.go b/dev-1/lesson-3.1/go/schema_repository.go index 82f7d8b..58eeff3 100644 --- a/dev-1/lesson-3.1/go/schema_repository.go +++ b/dev-1/lesson-3.1/go/schema_repository.go @@ -1,6 +1,7 @@ package main import ( + "context" "log" ) @@ -14,7 +15,7 @@ func NewSchemaRepository(query *QueryHelper) *SchemaRepository { } } -func (repo *SchemaRepository) CreateSchema() { +func (repo *SchemaRepository) CreateSchema(ctx context.Context) { err := repo.query.Execute(` CREATE TABLE IF NOT EXISTS issues ( id Int64 NOT NULL, @@ -23,14 +24,15 @@ func (repo *SchemaRepository) CreateSchema() { PRIMARY KEY (id) ); `, + ctx, ) if err != nil { log.Fatal(err) } } -func (repo *SchemaRepository) DropSchema() { - err := repo.query.Execute("DROP TABLE IF EXISTS issues;") +func (repo *SchemaRepository) DropSchema(ctx context.Context) { + err := repo.query.Execute("DROP TABLE IF EXISTS issues;", ctx) if err != nil { log.Fatal(err) } From 480c2618496a8b4ccf48a8f1825f4ee3dc4caeac Mon Sep 17 00:00:00 2001 From: danilov6083 Date: Mon, 1 Dec 2025 01:05:56 +0300 Subject: [PATCH 3/3] added comments --- dev-1/lesson-3.1/go/issue_repository.go | 35 ++++++++++++++++++++++-- dev-1/lesson-3.1/go/query_helper.go | 5 ++++ dev-1/lesson-3.1/go/schema_repository.go | 10 +++++++ 3 files changed, 48 insertions(+), 2 deletions(-) diff --git a/dev-1/lesson-3.1/go/issue_repository.go b/dev-1/lesson-3.1/go/issue_repository.go index 29b61cb..3093087 100644 --- a/dev-1/lesson-3.1/go/issue_repository.go +++ b/dev-1/lesson-3.1/go/issue_repository.go @@ -17,6 +17,8 @@ var ( ) ) +// Репозиторий для работы с тикетами в базе данных YDB +// Реализует операции добавления и чтения тикетов type IssueRepository struct { query *QueryHelper } @@ -27,10 +29,17 @@ func NewIssueRepository(query *QueryHelper) *IssueRepository { } } +// Добавление нового тикета в БД +// ctx [context.Context] - контекст для управления исполнением запроса (например, можно задать таймаут) +// title [string] - название тикета +// Возвращает созданный тикет или ошибку func (repo *IssueRepository) AddIssue(ctx context.Context, title string) (*Issue, error) { + // Генерируем случайный id для тикета id := random.Int63() // do not repeat in production timestamp := time.Now() + // Выполняем UPSERT запрос для добавления тикета + // Изменять данные можно только в режиме транзакции SERIALIZABLE_RW, поэтому используем его err := repo.query.ExecuteTx(` DECLARE $id AS Int64; DECLARE $title AS Text; @@ -58,9 +67,17 @@ func (repo *IssueRepository) AddIssue(ctx context.Context, title string) (*Issue }, nil } +// Возвращает тикет по заданному id +// ctx [context.Context] - контекст для управления исполнением запроса (например, можно задать таймаут) +// id [int64] - id тикета +// Возвращает найденный тикет или ошибку func (repo *IssueRepository) FindById(ctx context.Context, id int64) (*Issue, error) { result := make([]Issue, 0) + // Выполняем SELECT запрос в режиме [Snapshot Read-Only] для чтения данных + // Этот режим сообщает серверу, что эта транзакция только для чтения. + // Это позволяет снизить накладные расходы на подготовку к изменениям + // и просто читать данные из одного "слепка" базы данных. repo.query.Query(` SELECT id, @@ -76,6 +93,10 @@ func (repo *IssueRepository) FindById(ctx context.Context, id int64) (*Issue, er Build(), func(resultSet query.ResultSet, ctx context.Context) error { for row, err := range sugar.UnmarshalRows[Issue](resultSet.Rows(ctx)) { + // Если во время чтения результата возникла ошибка, + // то необходимо очистить уже прочитанные результаты, + // чтобы избежать дублирования при следующем выполнении функции-ретраера + // и вернуть ретраеру ошибку if err != nil { clear(result) return err @@ -88,17 +109,23 @@ func (repo *IssueRepository) FindById(ctx context.Context, id int64) (*Issue, er ) if len(result) > 1 { - return nil, errors.New("Multiple rows with the same id") + return nil, errors.New("Multiple rows with the same id (lol)") } if len(result) == 0 { - return nil, errors.New("Did not find any issues (lol)") + return nil, errors.New("Did not find any issues") } return &result[0], nil } +// Получает все тикеты из базы данных +// ctx [context.Context] - контекст для управления исполнением запроса (например, можно задать таймаут) func (repo *IssueRepository) FindAll(ctx context.Context) ([]Issue, error) { result := make([]Issue, 0) + // Выполняем SELECT запрос в режиме [Snapshot Read-Only] для чтения данных + // Этот режим сообщает серверу, что эта транзакция только для чтения. + // Это позволяет снизить накладные расходы на подготовку к изменениям + // и просто читать данные из одного "слепка" базы данных. err := repo.query.Query(` SELECT id, @@ -111,6 +138,10 @@ func (repo *IssueRepository) FindAll(ctx context.Context) ([]Issue, error) { ydb.ParamsBuilder().Build(), func(resultSet query.ResultSet, ctx context.Context) error { for row, err := range sugar.UnmarshalRows[Issue](resultSet.Rows(ctx)) { + // Если во время чтения результата возникла ошибка, + // то необходимо очистить уже прочитанные результаты, + // чтобы избежать дублирования при следующем выполнении функции-ретраера + // и вернуть ретраеру ошибку if err != nil { clear(result) return err diff --git a/dev-1/lesson-3.1/go/query_helper.go b/dev-1/lesson-3.1/go/query_helper.go index b88b568..1063ddf 100644 --- a/dev-1/lesson-3.1/go/query_helper.go +++ b/dev-1/lesson-3.1/go/query_helper.go @@ -9,6 +9,11 @@ import ( "github.com/ydb-platform/ydb-go-sdk/v3/query" ) +// Хелпер для выполнения запросов +// 1) Реализует Dependency Injection (принимает в функции-конструкторе указатель на драйвер). +// Это улучшает тестируемость - можно передать mock-объект для тестов +// 2) Универсальная логика выполнения запросов и чтения результатов +// 3) В методах принимает контекст, который может управлять исполнением запросов (например, через таймаут) type QueryHelper struct { driver *ydb.Driver } diff --git a/dev-1/lesson-3.1/go/schema_repository.go b/dev-1/lesson-3.1/go/schema_repository.go index 58eeff3..9572f2a 100644 --- a/dev-1/lesson-3.1/go/schema_repository.go +++ b/dev-1/lesson-3.1/go/schema_repository.go @@ -5,6 +5,8 @@ import ( "log" ) +// Репозиторий для управления схемой базы данных YDB +// Отвечает за создание и удаление таблиц type SchemaRepository struct { query *QueryHelper } @@ -15,6 +17,12 @@ func NewSchemaRepository(query *QueryHelper) *SchemaRepository { } } +// Создает таблицу issues в базе данных +// Таблица содержит поля: +// - id: уникальный идентификатор тикета +// - title: название тикета +// - created_at: время создания тикета +// Все поля являются обязательными. func (repo *SchemaRepository) CreateSchema(ctx context.Context) { err := repo.query.Execute(` CREATE TABLE IF NOT EXISTS issues ( @@ -31,6 +39,8 @@ func (repo *SchemaRepository) CreateSchema(ctx context.Context) { } } +// Удаляет таблицу issues из базы данных +// Используется для очистки схемы перед созданием новой func (repo *SchemaRepository) DropSchema(ctx context.Context) { err := repo.query.Execute("DROP TABLE IF EXISTS issues;", ctx) if err != nil {