PgGraph គឺជាឧបករណ៍ប្រើប្រាស់សម្រាប់ការរក្សាទុក និងស្វែងរកភាពអាស្រ័យតារាងនៅក្នុង PostgreSQL

ថ្ងៃនេះខ្ញុំចង់បង្ហាញអ្នកអាន Habr ជាមួយនឹងឧបករណ៍ប្រើប្រាស់ដែលសរសេរនៅក្នុង Python សម្រាប់ធ្វើការជាមួយតារាង dependencies នៅក្នុង PostgreSQL DBMS ។

API របស់ឧបករណ៍ប្រើប្រាស់គឺសាមញ្ញ ហើយមានវិធីបីយ៉ាង៖

• archive_table - ការរក្សាទុក/លុបជួរដេកដដែលៗជាមួយនឹងសោបឋមដែលបានបញ្ជាក់
• get_table_references - ស្វែងរកភាពអាស្រ័យសម្រាប់តារាង (នឹងបង្ហាញតារាងដែលយោងដោយតារាងដែលបានបញ្ជាក់ និងអ្នកដែលយោងវា)
• get_rows_references - ស្វែងរក​ជួរ​ដេក​ក្នុង​តារាង​ផ្សេង​ទៀត​ដែល​យោង​ជួរ​ដេក​ដែល​បាន​បញ្ជាក់​ក្នុង​តារាង​ដែល​ចង់​បាន។

សម័យបុរេប្រវត្តិសាស្ត្រ

ឈ្មោះរបស់ខ្ញុំគឺ Oleg Borzov ខ្ញុំជាអ្នកអភិវឌ្ឍន៍នៅក្នុងក្រុម CRM សម្រាប់អ្នកគ្រប់គ្រងប្រាក់កម្ចីទិញផ្ទះនៅ Domklik ។

មូលដ្ឋានទិន្នន័យសំខាន់នៃប្រព័ន្ធ CRM របស់យើងគឺជាផ្នែកមួយនៃទំហំធំបំផុតនៅក្នុងក្រុមហ៊ុន។ វាក៏ជាក្រុមហ៊ុនចាស់ជាងគេមួយដែរ៖ វាបានបង្ហាញខ្លួននៅក្នុងកម្មវិធីសម្ពោធគម្រោង នៅពេលដែលដើមឈើធំ ដូមគ្លីក គឺជាការចាប់ផ្តើមមួយ ហើយជំនួសឱ្យសេវាកម្មខ្នាតតូចនៅលើក្របខណ្ឌ Python asynchronous ម៉ូដទាន់សម័យ មាន monolith ដ៏ធំមួយនៅក្នុង PHP ។

ការផ្លាស់ប្តូរពី PHP ទៅ Python មានរយៈពេលយូរណាស់ ហើយត្រូវការការគាំទ្រដំណាលគ្នានៃប្រព័ន្ធទាំងពីរ ដែលប៉ះពាល់ដល់ការរចនានៃមូលដ្ឋានទិន្នន័យ។

ជាលទ្ធផល យើងមានមូលដ្ឋានទិន្នន័យដែលមានចំនួនដ៏ច្រើននៃតារាងដែលមានទំនាក់ទំនងខ្ពស់ និងធំជាមួយនឹងចង្កោមនៃលិបិក្រមសម្រាប់ប្រភេទសំណួរផ្សេងៗគ្នា។ ទាំងអស់នេះជះឥទ្ធិពលអវិជ្ជមានដល់ដំណើរការនៃមូលដ្ឋានទិន្នន័យ៖ ដោយសារតារាងធំ និងទំនាក់ទំនងរវាងពួកវា ភាពស្មុគស្មាញនៃសំណួរកំពុងកើនឡើងឥតឈប់ឈរ ដែលមានសារៈសំខាន់ជាពិសេសសម្រាប់តារាងដែលផ្ទុកច្រើនបំផុត។

ដើម្បីកាត់បន្ថយការផ្ទុកនៅលើមូលដ្ឋានទិន្នន័យ យើងបានសម្រេចចិត្តសរសេរស្គ្រីបដែលនឹងផ្ទេរកំណត់ត្រាចាស់ពីតារាងដែលមានពន្លឺ និងផ្ទុកច្រើនបំផុតទៅឯកសារដែលបានរក្សាទុក (ឧទាហរណ៍ ពី task в task_archive).

កិច្ចការនេះមានភាពស្មុគស្មាញដោយចំនួនទំនាក់ទំនងដ៏ច្រើនរវាងតារាង៖ គ្រាន់តែផ្លាស់ទីជួរដេកពី task в task_archive គឺមិនគ្រប់គ្រាន់ទេ មុនពេលនោះ អ្នកត្រូវធ្វើដូចគ្នាដដែលៗជាមួយនឹងការយោងទាំងអស់នោះ។ task តុ។

ខ្ញុំនឹងបង្ហាញជាមួយឧទាហរណ៍មួយ។ មូលដ្ឋានទិន្នន័យសាកល្បងពីគេហទំព័រ postgrespro.ru:

ឧបមាថាយើងត្រូវលុបកំណត់ត្រាចេញពីតារាង Flights. Postgres នឹងមិនអនុញ្ញាតឱ្យយើងធ្វើដូចនេះទេ៖ ដំបូងយើងត្រូវលុបកំណត់ត្រាចេញពីតារាងយោងទាំងអស់ ហើយបន្តបន្ទាប់ទៀតចុះទៅតារាងដែលមិនត្រូវបានយោងដោយនរណាម្នាក់។

នៅក្នុងឧទាហរណ៍របស់យើងនៅ Flights សំដៅទៅ Ticket_flightsនិងនៅលើនាង - Boarding_passes.

ដូច្នេះអ្នកត្រូវលុបវាតាមលំដាប់នេះ៖

1. យើងទទួលបានតម្លៃសោចម្បង (PK) នៃជួរដេកក្នុង Ticket_flightsដែលសំដៅលើជួរដេកដែលត្រូវលុបចេញ Flights.
2. យើងទទួលបានជួរ PK Boarding_passesដែលសំដៅលើ Ticket_flights.
3. យើងលុបជួរដោយ PK ពីជំហានទី 2 នៅក្នុងតារាង Boarding_passes.
4. លុបបន្ទាត់ដោយ PK ពីជំហានទី 1 ក្នុង Ticket_flights.
5. ការដកបន្ទាត់ចេញពី Flights.

លទ្ធផលគឺជាឧបករណ៍ប្រើប្រាស់មួយឈ្មោះថា PgGraph ដែលយើងបានសម្រេចចិត្តបង្កើតប្រភពបើកចំហ។

របៀបប្រើ

ឧបករណ៍ប្រើប្រាស់គាំទ្ររបៀបប្រើប្រាស់ពីរ៖

• ហៅចេញពីបន្ទាត់ពាក្យបញ្ជា (pggraph …).
• ការប្រើប្រាស់នៅក្នុងកូដ Python (ថ្នាក់ PgGraphApi).

ការតំឡើងនិងកំណត់រចនាសម្ព័ន្ធ

ដំបូងអ្នកត្រូវដំឡើងឧបករណ៍ប្រើប្រាស់ពីឃ្លាំង Pypi៖

pip3 install pggraph

បន្ទាប់មកបង្កើតឯកសារ config.ini នៅលើម៉ាស៊ីនមូលដ្ឋានជាមួយនឹងការកំណត់រចនាសម្ព័ន្ធនៃមូលដ្ឋានទិន្នន័យ និងស្គ្រីបទុកក្នុងប័ណ្ណសារ៖

[db]
host = localhost
port = 5432
user = postgres
password = postgres
dbname = postgres
schema = public ; Необязательный параметр, указано значение по умолчанию

[archive]  ; Данный раздел заполнять необязательно, ниже указаны значения по умолчанию
is_debug = false
chunk_size = 1000
max_depth = 20
to_archive = true
archive_suffix = 'archive'

រត់ពីកុងសូល។

ប៉ារ៉ាម៉ែត្រ

$ pggraph -h
usage: pggraph action [-h] --table TABLE [--ids IDS] [--config_path CONFIG_PATH]
positional arguments:
  action        required action: archive_table, get_table_references, get_rows_references

optional arguments:
  -h, --help                    show this help message and exit
  --table TABLE                 table name
  --ids IDS                     primary key ids, separated by comma, e.g. 1,2,3
  --config_path CONFIG_PATH     path to config.ini
  --log_path LOG_PATH           path to log dir
  --log_level LOG_LEVEL         log level (debug, info, error)

អាគុយម៉ង់ទីតាំង៖

• action - សកម្មភាពដែលត្រូវការ៖ archive_table, get_table_references ឬ get_rows_references.

អាគុយម៉ង់ដែលមានឈ្មោះ៖

• --config_path - ផ្លូវទៅកាន់ឯកសារកំណត់រចនាសម្ព័ន្ធ;
• --table - តារាងដែលអ្នកត្រូវការដើម្បីអនុវត្តសកម្មភាពមួយ;
• --ids - បញ្ជីលេខសម្គាល់ដែលបំបែកដោយសញ្ញាក្បៀស ឧទាហរណ៍ 1,2,3 (ប៉ារ៉ាម៉ែត្រស្រេចចិត្ត);
• --log_path - ផ្លូវទៅកាន់ថតសម្រាប់កំណត់ហេតុ (ប៉ារ៉ាម៉ែត្រស្រេចចិត្ត តាមលំនាំដើម — ថតផ្ទះ);
• --log_level - កម្រិតនៃការកត់ត្រា (ប៉ារ៉ាម៉ែត្រស្រេចចិត្ត លំនាំដើមគឺ INFO)។

ឧទាហរណ៍ពាក្យបញ្ជា

ការរក្សាទុកតារាង

មុខងារសំខាន់របស់ឧបករណ៍ប្រើប្រាស់គឺការរក្សាទុកទិន្នន័យ i.e. ការផ្ទេរជួរពីតារាងមេទៅតារាងបណ្ណសារ (ឧទាហរណ៍ ពីតារាង សៀវភៅ в books_archive).

ការលុបដោយគ្មានការរក្សាទុកក្នុងប័ណ្ណសារក៏ត្រូវបានគាំទ្រផងដែរ៖ សម្រាប់បញ្ហានេះអ្នកត្រូវកំណត់ប៉ារ៉ាម៉ែត្រនៅក្នុង config.ini to_archive = មិនពិត).

ប៉ារ៉ាម៉ែត្រដែលត្រូវការ - config_path តារាង និងលេខសម្គាល់.

បន្ទាប់ពីបើកដំណើរការ កំណត់ត្រានឹងត្រូវបានលុបឡើងវិញ ids នៅក្នុងតារាង table ហើយនៅក្នុងតារាងទាំងអស់ដែលសំដៅទៅលើវា។

$ pggraph archive_table --config_path config.hw.local.ini --table flights --ids 1,2,3
2020-06-20 19:27:44 INFO: flights - START
2020-06-20 19:27:44 INFO: flights - start archive_recursive 3 rows (depth=0)
2020-06-20 19:27:44 INFO:       START ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:       ticket_flights - start archive_recursive 3 rows (depth=1)
2020-06-20 19:27:44 INFO:               START ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:               boarding_passes - start archive_recursive 3 rows (depth=2)
2020-06-20 19:27:44 INFO:                       START ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:                       END ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:               boarding_passes - archive_by_ids 3 rows by ticket_no, flight_id
2020-06-20 19:27:44 INFO:               boarding_passes - start archive_recursive 3 rows (depth=2)
2020-06-20 19:27:44 INFO:                       START ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:                       END ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:               boarding_passes - archive_by_ids 3 rows by ticket_no, flight_id
2020-06-20 19:27:44 INFO:               boarding_passes - start archive_recursive 3 rows (depth=2)
2020-06-20 19:27:44 INFO:                       START ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:                       END ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:               boarding_passes - archive_by_ids 3 rows by ticket_no, flight_id
2020-06-20 19:27:44 INFO:               boarding_passes - start archive_recursive 3 rows (depth=2)
2020-06-20 19:27:44 INFO:                       START ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:                       END ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:               boarding_passes - archive_by_ids 3 rows by ticket_no, flight_id
2020-06-20 19:27:44 INFO:               END ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO:       ticket_flights - archive_by_ids 3 rows by ticket_no, flight_id
2020-06-20 19:27:44 INFO:       END ARCHIVE REFERRING TABLES
2020-06-20 19:27:44 INFO: flights - archive_by_ids 3 rows by id
2020-06-20 19:27:44 INFO: flights - END

ស្វែងរកភាពអាស្រ័យសម្រាប់តារាងដែលបានបញ្ជាក់

មុខងារស្វែងរកភាពអាស្រ័យនៃតារាងដែលបានបញ្ជាក់ table. ប៉ារ៉ាម៉ែត្រដែលត្រូវការ - config_path и table.

បន្ទាប់ពីបើកដំណើរការ វចនានុក្រមនឹងត្រូវបានបង្ហាញនៅលើអេក្រង់ ដែលជាកន្លែងដែល៖

• in_refs — វចនានុក្រម​តារាង​យោង​មួយ​ដែល​បាន​ផ្តល់​ឱ្យ​ដែល​កូនសោ​ជា​ឈ្មោះ​តារាង តម្លៃ​គឺ​ជា​បញ្ជី​វត្ថុ​សោបរទេស (pk_main - គន្លឹះសំខាន់ក្នុងតារាងមេ pk_ref - គន្លឹះចម្បងនៅក្នុងតារាងយោង, fk_ref - ឈ្មោះ​ជួរ​ឈរ​ដែល​ជា​គន្លឹះ​បរទេស​ទៅ​តារាង​ប្រភព);
• out_refs — វចនានុក្រម​តារាង​មួយ​នេះ​សំដៅ​លើ។

$ pggraph get_table_references --config_path config.hw.local.ini --table flights
{'in_refs': {'ticket_flights': [ForeignKey(pk_main='flight_id', pk_ref='ticket_no, flight_id', fk_ref='flight_id')]},
 'out_refs': {'aircrafts': [ForeignKey(pk_main='aircraft_code', pk_ref='flight_id', fk_ref='aircraft_code')],
              'airports': [ForeignKey(pk_main='airport_code', pk_ref='flight_id', fk_ref='arrival_airport'),
                           ForeignKey(pk_main='airport_code', pk_ref='flight_id', fk_ref='departure_airport')]}}

ស្វែងរកសេចក្តីយោងទៅខ្សែអក្សរដោយប្រើសោបឋមដែលបានបញ្ជាក់

មុខងារដើម្បីស្វែងរកជួរដេកក្នុងតារាងផ្សេងទៀតដែលសំដៅលើជួរដេកតាមរយៈ Foreign Key ids តុ។ table. ប៉ារ៉ាម៉ែត្រដែលត្រូវការ - config_path, table и ids.

បន្ទាប់ពីបើកដំណើរការ វចនានុក្រមដែលមានរចនាសម្ព័ន្ធដូចខាងក្រោមនឹងត្រូវបានបង្ហាញនៅលើអេក្រង់៖

{
	pk_id_1: {
		reffering_table_name_1: {
			foreign_key_1: [
				{row_pk_1: value, row_pk_2: value},
				...
			], 
			...
		},
		...
	},
	pk_id_2: {...},
	...
}

ឧទាហរណ៍ការហៅទូរសព្ទ៖

$ pggraph get_rows_references --config_path config.hw.local.ini --table flights --ids 1,2,3
{1: {'ticket_flights': {'flight_id': [{'flight_id': 1,
                                       'ticket_no': '0005432816945'},
                                      {'flight_id': 1,
                                       'ticket_no': '0005432816941'}]}},
 2: {'ticket_flights': {'flight_id': [{'flight_id': 2,
                                       'ticket_no': '0005433101832'},
                                      {'flight_id': 2,
                                       'ticket_no': '0005433101864'},
                                      {'flight_id': 2,
                                       'ticket_no': '0005432919715'}]}},
 3: {'ticket_flights': {'flight_id': [{'flight_id': 3,
                                       'ticket_no': '0005432817560'},
                                      {'flight_id': 3,
                                       'ticket_no': '0005432817568'},
                                      {'flight_id': 3,
                                       'ticket_no': '0005432817559'}]}}}

ការប្រើប្រាស់កូដ

បន្ថែមពីលើការដំណើរការវានៅក្នុងកុងសូល បណ្ណាល័យអាចត្រូវបានប្រើនៅក្នុងកូដ Python ។ ឧទាហរណ៍នៃការហៅទូរសព្ទនៅក្នុងបរិយាកាសអន្តរកម្ម iPython ត្រូវបានបង្ហាញខាងក្រោម។

ការរក្សាទុកតារាង

>>> from pg_graph.main import setup_logging
>>> setup_logging(log_level='DEBUG')
>>> from pg_graph.api import PgGraphApi
>>> api = PgGraphApi('config.hw.local.ini')
>>> api.archive_table('flights', [4,5])
2020-06-20 23:12:08 INFO: flights - START
2020-06-20 23:12:08 INFO: flights - start archive_recursive 2 rows (depth=0)
2020-06-20 23:12:08 INFO: 	START ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 DEBUG: 	ticket_flights - ForeignKey(pk_main='flight_id', pk_ref='flight_id, ticket_no', fk_ref='flight_id')
2020-06-20 23:12:08 DEBUG: 	SQL('SELECT flight_id, ticket_no FROM bookings.ticket_flights WHERE (flight_id) IN (%s, %s)')
2020-06-20 23:12:08 INFO: 	ticket_flights - start archive_recursive 30 rows (depth=1)
2020-06-20 23:12:08 INFO: 		START ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 DEBUG: 		boarding_passes - ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 INFO: 		boarding_passes - archive_by_fk 30 rows by ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 DEBUG: 		SQL('CREATE TABLE IF NOT EXISTS bookings.boarding_passes_archive (LIKE bookings.boarding_passes)')
2020-06-20 23:12:08 DEBUG: 		DELETE FROM boarding_passes by FK flight_id, ticket_no - 30 rows
2020-06-20 23:12:08 INFO: 		END ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 INFO: 	ticket_flights - archive_by_ids 30 rows by flight_id, ticket_no
2020-06-20 23:12:08 DEBUG: 	SQL('CREATE TABLE IF NOT EXISTS bookings.ticket_flights_archive (LIKE bookings.ticket_flights)')
2020-06-20 23:12:08 DEBUG: 	DELETE FROM ticket_flights by flight_id, ticket_no - 30 rows
2020-06-20 23:12:08 DEBUG: 	INSERT INTO ticket_flights_archive - 30 rows
2020-06-20 23:12:08 INFO: 	ticket_flights - start archive_recursive 30 rows (depth=1)
2020-06-20 23:12:08 INFO: 		START ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 DEBUG: 		boarding_passes - ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 INFO: 		boarding_passes - archive_by_fk 30 rows by ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 DEBUG: 		SQL('CREATE TABLE IF NOT EXISTS bookings.boarding_passes_archive (LIKE bookings.boarding_passes)')
2020-06-20 23:12:08 DEBUG: 		DELETE FROM boarding_passes by FK flight_id, ticket_no - 30 rows
2020-06-20 23:12:08 INFO: 		END ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 INFO: 	ticket_flights - archive_by_ids 30 rows by flight_id, ticket_no
2020-06-20 23:12:08 DEBUG: 	SQL('CREATE TABLE IF NOT EXISTS bookings.ticket_flights_archive (LIKE bookings.ticket_flights)')
2020-06-20 23:12:08 DEBUG: 	DELETE FROM ticket_flights by flight_id, ticket_no - 30 rows
2020-06-20 23:12:08 DEBUG: 	INSERT INTO ticket_flights_archive - 30 rows
2020-06-20 23:12:08 INFO: 	ticket_flights - start archive_recursive 30 rows (depth=1)
2020-06-20 23:12:08 INFO: 		START ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 DEBUG: 		boarding_passes - ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 INFO: 		boarding_passes - archive_by_fk 30 rows by ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 DEBUG: 		SQL('CREATE TABLE IF NOT EXISTS bookings.boarding_passes_archive (LIKE bookings.boarding_passes)')
2020-06-20 23:12:08 DEBUG: 		DELETE FROM boarding_passes by FK flight_id, ticket_no - 30 rows
2020-06-20 23:12:08 INFO: 		END ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 INFO: 	ticket_flights - archive_by_ids 30 rows by flight_id, ticket_no
2020-06-20 23:12:08 DEBUG: 	SQL('CREATE TABLE IF NOT EXISTS bookings.ticket_flights_archive (LIKE bookings.ticket_flights)')
2020-06-20 23:12:08 DEBUG: 	DELETE FROM ticket_flights by flight_id, ticket_no - 30 rows
2020-06-20 23:12:08 DEBUG: 	INSERT INTO ticket_flights_archive - 30 rows
2020-06-20 23:12:08 INFO: 	ticket_flights - start archive_recursive 3 rows (depth=1)
2020-06-20 23:12:08 INFO: 		START ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 DEBUG: 		boarding_passes - ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 INFO: 		boarding_passes - archive_by_fk 3 rows by ForeignKey(pk_main='flight_id, ticket_no', pk_ref='flight_id, ticket_no', fk_ref='flight_id, ticket_no')
2020-06-20 23:12:08 DEBUG: 		SQL('CREATE TABLE IF NOT EXISTS bookings.boarding_passes_archive (LIKE bookings.boarding_passes)')
2020-06-20 23:12:08 DEBUG: 		DELETE FROM boarding_passes by FK flight_id, ticket_no - 3 rows
2020-06-20 23:12:08 INFO: 		END ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 INFO: 	ticket_flights - archive_by_ids 3 rows by flight_id, ticket_no
2020-06-20 23:12:08 DEBUG: 	SQL('CREATE TABLE IF NOT EXISTS bookings.ticket_flights_archive (LIKE bookings.ticket_flights)')
2020-06-20 23:12:08 DEBUG: 	DELETE FROM ticket_flights by flight_id, ticket_no - 3 rows
2020-06-20 23:12:08 DEBUG: 	INSERT INTO ticket_flights_archive - 3 rows
2020-06-20 23:12:08 INFO: 	END ARCHIVE REFERRING TABLES
2020-06-20 23:12:08 INFO: flights - archive_by_ids 2 rows by flight_id
2020-06-20 23:12:09 DEBUG: SQL('CREATE TABLE IF NOT EXISTS bookings.flights_archive (LIKE bookings.flights)')
2020-06-20 23:12:09 DEBUG: DELETE FROM flights by flight_id - 2 rows
2020-06-20 23:12:09 DEBUG: INSERT INTO flights_archive - 2 rows
2020-06-20 23:12:09 INFO: flights - END

ស្វែងរកភាពអាស្រ័យសម្រាប់តារាងដែលបានបញ្ជាក់

>>> from pg_graph.api import PgGraphApi
>>> from pprint import pprint
>>> api = PgGraphApi('config.hw.local.ini')
>>> res = api.get_table_references('flights')
>>> pprint(res)
{'in_refs': {'ticket_flights': [ForeignKey(pk_main='flight_id', pk_ref='flight_id, ticket_no', fk_ref='flight_id')]},
 'out_refs': {'aircrafts': [ForeignKey(pk_main='aircraft_code', pk_ref='flight_id', fk_ref='aircraft_code')],
              'airports': [ForeignKey(pk_main='airport_code', pk_ref='flight_id', fk_ref='arrival_airport'),
                           ForeignKey(pk_main='airport_code', pk_ref='flight_id', fk_ref='departure_airport')]}}

ស្វែងរកសេចក្តីយោងទៅខ្សែអក្សរដោយប្រើសោបឋមដែលបានបញ្ជាក់

>>> from pg_graph.api import PgGraphApi
>>> from pprint import pprint
>>> api = PgGraphApi('config.hw.local.ini')
>>> rows = api.get_rows_references('flights', [1,2,3])
>>> pprint(rows)
{1: {'ticket_flights': {'flight_id': [{'flight_id': 1,
                                       'ticket_no': '0005432816945'},
                                      {'flight_id': 1,
                                       'ticket_no': '0005432816941'}]}},
 2: {'ticket_flights': {'flight_id': [{'flight_id': 2,
                                       'ticket_no': '0005433101832'},
                                      {'flight_id': 2,
                                       'ticket_no': '0005433101864'},
                                      {'flight_id': 2,
                                       'ticket_no': '0005432919715'}]}},
 3: {'ticket_flights': {'flight_id': [{'flight_id': 3,
                                       'ticket_no': '0005432817560'},
                                      {'flight_id': 3,
                                       'ticket_no': '0005432817568'},
                                      {'flight_id': 3,
                                       'ticket_no': '0005432817559'}]}}}

កូដប្រភពបណ្ណាល័យមាននៅ GitHub នៅក្រោមអាជ្ញាប័ណ្ណ MIT ក៏ដូចជានៅក្នុងឃ្លាំង ភីភីអាយ។.

ខ្ញុំនឹងរីករាយចំពោះមតិយោបល់ ការប្តេជ្ញាចិត្ត និងការផ្ដល់យោបល់។

ខ្ញុំនឹងព្យាយាមឆ្លើយសំណួរឱ្យអស់ពីសមត្ថភាពរបស់ខ្ញុំនៅទីនេះ និងក្នុងឃ្លាំង។

ប្រភព: www.habr.com