You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
72 lines
1.9 KiB
72 lines
1.9 KiB
2 years ago
|
<?php
|
||
|
|
|
||
|
|
require('header_auth.php');
|
||
|
|
header_auth('Qnb7jfeGZM');
|
||
|
|
|
||
|
|
require('http_errors.php');
|
||
|
|
|
||
|
|
if (empty($_FILES['csv']) || empty($_POST['classes'])) {
|
||
|
|
HttpResponse::bad_request()->set_and_exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
$types = array();
|
||
|
|
|
||
|
|
foreach (explode("\n", $_POST['classes']) as $line) {
|
||
|
|
$split = explode(' ', $line);
|
||
|
|
$name = $split[0];
|
||
|
|
$type = $split[1];
|
||
|
|
if ($type === 'cell') {
|
||
|
|
$type = 'text not null';
|
||
|
|
} else if ($type === 'logical') {
|
||
|
|
$type = 'boolean not null';
|
||
|
|
}
|
||
|
|
$types[$name] = $type;
|
||
|
|
}
|
||
|
|
|
||
|
|
$csv_fd = fopen($_FILES['csv']['tmp_name'], 'r');
|
||
|
|
$column_names = fgetcsv($csv_fd);
|
||
|
|
|
||
|
|
$sql_columns = '';
|
||
|
|
foreach ($column_names as $column_name) {
|
||
|
|
if ($column_name === 'setup_id') {
|
||
|
|
$sql_columns .= 'setup_id int not null,';
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
$no_number = preg_replace('/_[0-9]+$/', '', $column_name);
|
||
|
|
$sql_columns .= sprintf('%s %s,', $column_name, $types[$no_number]);
|
||
|
|
}
|
||
|
|
|
||
|
|
try {
|
||
|
|
$pdo = new PDO('mysql:host=localhost;dbname=observer', 'ziegmann', 'Zieg7+89');
|
||
|
|
|
||
|
|
$pdo->beginTransaction();
|
||
|
|
|
||
|
|
if ($pdo->exec('drop table computeddata;') === false) {
|
||
|
|
if ($pdo->errorCode() !== '42S02') { // Table does not exist
|
||
|
|
error_log(print_r($pdo->errorInfo(), true));
|
||
|
|
$pdo->rollBack();
|
||
|
|
HttpResponse::internal_server_error()->set_and_exit();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($pdo->exec(sprintf('create table computeddata ('
|
||
|
|
. 'id bigint primary key not null auto_increment,'
|
||
|
|
. '%s'
|
||
|
|
. 'constraint `fk_computeddata_setup`'
|
||
|
|
. 'foreign key (setup_id) references setup (setup_id)'
|
||
|
|
. 'on delete cascade on update restrict'
|
||
|
|
. ');', $sql_columns)) === false) {
|
||
|
|
error_log(print_r($pdo->errorInfo(), true));
|
||
|
|
$pdo->rollBack();
|
||
|
|
HttpResponse::internal_server_error()->set_and_exit();
|
||
|
|
}
|
||
|
|
|
||
|
|
$pdo->commit();
|
||
|
|
} catch (Exception $e) {
|
||
|
|
error_log($e->getMessage());
|
||
|
|
if (isset($pdo) && $pdo->inTransaction()) {
|
||
|
|
$pdo->rollBack();
|
||
|
|
}
|
||
|
|
HttpResponse::internal_server_error()->set_and_exit();
|
||
|
|
}
|