Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| c1904f9ef2 |
2
DBs/.gitignore
vendored
Normal file
2
DBs/.gitignore
vendored
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
*.pdf
|
||||||
|
|
||||||
23
DBs/README.md
Normal file
23
DBs/README.md
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
# Базы данных
|
||||||
|
|
||||||
|
Тут будут лежать лабы по PostgreSQL.
|
||||||
|
|
||||||
|
## Структура
|
||||||
|
|
||||||
|
В корне есть файл `main.typ`. Его можно скомпилировать с помощью
|
||||||
|
|
||||||
|
```
|
||||||
|
typst c main.typ
|
||||||
|
```
|
||||||
|
|
||||||
|
Внутри него есть директивы включения файлов с лабами.
|
||||||
|
|
||||||
|
В каждой директории `^lab\d+\/$` есть как минимум один файл `main.typ`,
|
||||||
|
которые и включаются в корневой `main.typ`. Это позволяет формировать структурированный отчет
|
||||||
|
для курсовика.
|
||||||
|
|
||||||
|
## Окружение
|
||||||
|
|
||||||
|
- Я использую `docker.io/library/postgres:16.10-alpine3.2` в контейнере `podman`
|
||||||
|
- Для работы с БД - `pgcli`
|
||||||
|
|
||||||
72
DBs/lab1/main.typ
Normal file
72
DBs/lab1/main.typ
Normal file
@ -0,0 +1,72 @@
|
|||||||
|
= Работа №1. Создание базы данных.
|
||||||
|
|
||||||
|
== Смена пароля
|
||||||
|
|
||||||
|
```sql
|
||||||
|
ALTER USER surimi WITH PASSWORD 'trio';
|
||||||
|
```
|
||||||
|
|
||||||
|
== Создание таблиц
|
||||||
|
|
||||||
|
```sql
|
||||||
|
-- create
|
||||||
|
CREATE TABLE auto_personnel (
|
||||||
|
id serial primary key,
|
||||||
|
first_name varchar(255),
|
||||||
|
last_name varchar(255),
|
||||||
|
father_name varchar(255)
|
||||||
|
);
|
||||||
|
COMMENT ON TABLE auto_personnel IS 'Сотрудники автопарка';
|
||||||
|
|
||||||
|
CREATE TABLE auto (
|
||||||
|
id serial primary key,
|
||||||
|
num varchar(255),
|
||||||
|
color varchar(255),
|
||||||
|
mark varchar(255)
|
||||||
|
);
|
||||||
|
COMMENT ON TABLE auto IS 'Автомобили автопарка';
|
||||||
|
|
||||||
|
CREATE TABLE routes (
|
||||||
|
id serial primary key,
|
||||||
|
name varchar(255)
|
||||||
|
);
|
||||||
|
COMMENT ON TABLE routes IS 'Маршруты';
|
||||||
|
|
||||||
|
CREATE TABLE journal (
|
||||||
|
id serial primary key,
|
||||||
|
time_out timestamp with time zone,
|
||||||
|
time_in timestamp with time zone
|
||||||
|
);
|
||||||
|
COMMENT ON TABLE journal IS 'Журнал оператора';
|
||||||
|
```
|
||||||
|
|
||||||
|
== Создание связей
|
||||||
|
|
||||||
|
```sql
|
||||||
|
ALTER TABLE journal ADD COLUMN route_id INTEGER NOT NULL CONSTRAINT fk_journal_routes REFERENCES routes(id);
|
||||||
|
ALTER TABLE journal ADD COLUMN auto_id INTEGER NOT NULL CONSTRAINT fk_journal_auto REFERENCES auto(id);
|
||||||
|
ALTER TABLE auto ADD COLUMN personnel_id INTEGER NOT NULL CONSTRAINT fk_auto_auto_personnel REFERENCES auto_personnel(id);
|
||||||
|
```
|
||||||
|
|
||||||
|
== Удаление таблиц
|
||||||
|
|
||||||
|
```sql
|
||||||
|
-- drop
|
||||||
|
DROP TABLE auto_personnel CASCADE;
|
||||||
|
DROP TABLE auto CASCADE;
|
||||||
|
DROP TABLE routes CASCADE;
|
||||||
|
DROP TABLE journal CASCADE;
|
||||||
|
```
|
||||||
|
|
||||||
|
== Бекап
|
||||||
|
|
||||||
|
```sh
|
||||||
|
podman exec postgresinstance-postgres-1 pg_dump postgres -U surimi > dump.sql
|
||||||
|
```
|
||||||
|
|
||||||
|
== Восстановление
|
||||||
|
|
||||||
|
```sh
|
||||||
|
podman exec -i postgresinstance-postgres-1 psql -U surimi -d postgres < dump.sql
|
||||||
|
```
|
||||||
|
|
||||||
10
DBs/main.typ
Normal file
10
DBs/main.typ
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
#import "@preview/ilm:1.4.1": *
|
||||||
|
|
||||||
|
#set text(lang: "ru")
|
||||||
|
|
||||||
|
#show: ilm.with(
|
||||||
|
title: [Базы данных],
|
||||||
|
author: "Марк Железняков",
|
||||||
|
)
|
||||||
|
|
||||||
|
#include "lab1/main.typ"
|
||||||
@ -1,12 +0,0 @@
|
|||||||
targets = main
|
|
||||||
all: $(targets)
|
|
||||||
|
|
||||||
main: main.o
|
|
||||||
$(CC) -o $@ $^ $(CFLAGS)
|
|
||||||
|
|
||||||
%.o: %.c
|
|
||||||
$(CC) -c $^ -o $@ $(CFLAGS)
|
|
||||||
|
|
||||||
clean:
|
|
||||||
rm -f $(targets)
|
|
||||||
rm -f *.o
|
|
||||||
Binary file not shown.
@ -1,99 +0,0 @@
|
|||||||
#include <stdio.h>
|
|
||||||
#include <stdbool.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <string.h>
|
|
||||||
#include <pthread.h>
|
|
||||||
#include <time.h>
|
|
||||||
#include <signal.h>
|
|
||||||
#include <semaphore.h>
|
|
||||||
#include <errno.h>
|
|
||||||
|
|
||||||
enum events{
|
|
||||||
EVENT_VICTIM_THREAD_READY,
|
|
||||||
EVENT_PRINT_BUFFER_UPDATED,
|
|
||||||
EVENTS_NR
|
|
||||||
};
|
|
||||||
|
|
||||||
enum threads_roles {
|
|
||||||
ROLE_VICTIM,
|
|
||||||
ROLE_KILLER,
|
|
||||||
ROLE_PRINTER,
|
|
||||||
ROLES_NR
|
|
||||||
};
|
|
||||||
|
|
||||||
#define ERR_PTR(ret) ((void*)(long)ret)
|
|
||||||
#define PRINTER_TIMEOUT_SECS 2
|
|
||||||
|
|
||||||
#define PRINT_BUFF_SIZE 256
|
|
||||||
static sem_t sems[EVENTS_NR];
|
|
||||||
static pthread_t threads[ROLES_NR];
|
|
||||||
static char print_buffer[PRINT_BUFF_SIZE];
|
|
||||||
static volatile bool run = true;
|
|
||||||
|
|
||||||
void sig_handler(int signal)
|
|
||||||
{
|
|
||||||
snprintf(print_buffer, PRINT_BUFF_SIZE, "signal %d recieved", signal);
|
|
||||||
pthread_exit(ERR_PTR(sem_post(&sems[EVENT_PRINT_BUFFER_UPDATED])));
|
|
||||||
}
|
|
||||||
|
|
||||||
void *killer_thread(void* _)
|
|
||||||
{
|
|
||||||
sigset_t ss;
|
|
||||||
sigemptyset(&ss);
|
|
||||||
sigaddset(&ss, SIGUSR1);
|
|
||||||
if (pthread_sigmask(SIG_BLOCK, &ss, NULL))
|
|
||||||
pthread_exit(ERR_PTR(-EFAULT));
|
|
||||||
int ret = sem_wait(&sems[EVENT_VICTIM_THREAD_READY]);
|
|
||||||
if (ret) pthread_exit(ERR_PTR(ret));
|
|
||||||
pthread_exit(ERR_PTR(pthread_kill(threads[ROLE_VICTIM], SIGUSR1)));
|
|
||||||
}
|
|
||||||
|
|
||||||
void *victim_thread(void* _)
|
|
||||||
{
|
|
||||||
int ret = sem_post(&sems[EVENT_VICTIM_THREAD_READY]);
|
|
||||||
if (ret) pthread_exit(ERR_PTR(ret));
|
|
||||||
volatile int x = 0; // for compiler not to optimize infinite loop
|
|
||||||
while (run) {
|
|
||||||
x++;
|
|
||||||
}
|
|
||||||
pthread_exit(NULL);
|
|
||||||
}
|
|
||||||
|
|
||||||
void *printer_thread(void* _)
|
|
||||||
{
|
|
||||||
sigset_t ss;
|
|
||||||
sigemptyset(&ss);
|
|
||||||
sigaddset(&ss, SIGUSR1);
|
|
||||||
if (pthread_sigmask(SIG_BLOCK, &ss, NULL)) pthread_exit(ERR_PTR(-EFAULT));
|
|
||||||
while (run) {
|
|
||||||
struct timespec ts = {0};
|
|
||||||
int ret = timespec_get(&ts, TIME_UTC);
|
|
||||||
if (ret != TIME_UTC) pthread_exit(ERR_PTR(-EFAULT));
|
|
||||||
ts.tv_sec += PRINTER_TIMEOUT_SECS;
|
|
||||||
if (sem_timedwait(&sems[EVENT_PRINT_BUFFER_UPDATED], &ts))
|
|
||||||
pthread_exit(ERR_PTR(-EFAULT));
|
|
||||||
puts(print_buffer);
|
|
||||||
memset(print_buffer, 0, PRINT_BUFF_SIZE);
|
|
||||||
}
|
|
||||||
pthread_exit(NULL);
|
|
||||||
}
|
|
||||||
|
|
||||||
#define DO_OR_FAIL(cond) if (cond) return EXIT_FAILURE
|
|
||||||
|
|
||||||
int main()
|
|
||||||
{
|
|
||||||
struct sigaction sa = {
|
|
||||||
.sa_handler = sig_handler,
|
|
||||||
};
|
|
||||||
DO_OR_FAIL(sigaction(SIGUSR1, &sa, NULL));
|
|
||||||
DO_OR_FAIL(sem_init(&sems[EVENT_VICTIM_THREAD_READY], 0, 0));
|
|
||||||
DO_OR_FAIL(sem_init(&sems[EVENT_PRINT_BUFFER_UPDATED], 0, 0));
|
|
||||||
DO_OR_FAIL(pthread_create(&threads[ROLE_KILLER], NULL, killer_thread, NULL));
|
|
||||||
DO_OR_FAIL(pthread_create(&threads[ROLE_PRINTER], NULL, printer_thread, NULL));
|
|
||||||
DO_OR_FAIL(pthread_create(&threads[ROLE_VICTIM], NULL, victim_thread, NULL));
|
|
||||||
|
|
||||||
for (size_t i = 0; i < ROLES_NR; i++) {
|
|
||||||
DO_OR_FAIL(pthread_join(threads[i], NULL));
|
|
||||||
}
|
|
||||||
return EXIT_SUCCESS;
|
|
||||||
}
|
|
||||||
Binary file not shown.
@ -1,12 +0,0 @@
|
|||||||
targets = main
|
|
||||||
all: $(targets)
|
|
||||||
|
|
||||||
main: main.o
|
|
||||||
$(CC) -o $@ $^ $(CFLAGS)
|
|
||||||
|
|
||||||
%.o: %.c
|
|
||||||
$(CC) -c $^ -o $@ $(CFLAGS)
|
|
||||||
|
|
||||||
clean:
|
|
||||||
rm -f $(targets)
|
|
||||||
rm -f *.o
|
|
||||||
@ -1,43 +0,0 @@
|
|||||||
#include <signal.h>
|
|
||||||
#include <stdio.h>
|
|
||||||
#include <stdlib.h>
|
|
||||||
#include <unistd.h>
|
|
||||||
#include <stdbool.h>
|
|
||||||
|
|
||||||
#define SLEEP_TIME 1
|
|
||||||
|
|
||||||
volatile int x;
|
|
||||||
|
|
||||||
void sigint_handler(int signal)
|
|
||||||
{
|
|
||||||
puts("sigint handler");
|
|
||||||
sleep(SLEEP_TIME);
|
|
||||||
}
|
|
||||||
|
|
||||||
void sigusr1_handler(int signal)
|
|
||||||
{
|
|
||||||
puts("sigusr1 handler");
|
|
||||||
kill(getpid(), SIGINT);
|
|
||||||
}
|
|
||||||
|
|
||||||
#define DO_OR_FAIL(cond) if (cond) return EXIT_FAILURE
|
|
||||||
int main()
|
|
||||||
{
|
|
||||||
struct sigaction sa_int = {
|
|
||||||
.sa_handler = sigint_handler
|
|
||||||
};
|
|
||||||
struct sigaction sa_usr1 = {
|
|
||||||
.sa_handler = sigusr1_handler
|
|
||||||
};
|
|
||||||
struct sigaction old_sa = {0};
|
|
||||||
DO_OR_FAIL(sigemptyset(&sa_int.sa_mask));
|
|
||||||
DO_OR_FAIL(sigemptyset(&sa_usr1.sa_mask));
|
|
||||||
DO_OR_FAIL(sigaddset(&sa_int.sa_mask, SIGINT));
|
|
||||||
DO_OR_FAIL(sigaddset(&sa_usr1.sa_mask, SIGUSR1));
|
|
||||||
DO_OR_FAIL(sigaction(SIGINT, &sa_int, &old_sa));
|
|
||||||
DO_OR_FAIL(sigaction(SIGUSR1, &sa_usr1, NULL));
|
|
||||||
while (true) {
|
|
||||||
x++; // чтобы не соптимизировался
|
|
||||||
}
|
|
||||||
return EXIT_SUCCESS;
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user