Skip to content
GitLab
Explorer
Connexion
Navigation principale
Rechercher ou aller à…
Projet
lektor
Gestion
Activité
Membres
Labels
Programmation
Tickets
Tableaux des tickets
Jalons
Code
Requêtes de fusion
Dépôt
Branches
Validations
Étiquettes
Graphe du dépôt
Comparer les révisions
Compilation
Pipelines
Jobs
Planifications de pipeline
Artéfacts
Aide
Aide
Support
Documentation de GitLab
Comparer les forfaits GitLab
Forum de la communauté GitLab
Contribuer à GitLab
Donner votre avis
Raccourcis clavier
?
Extraits de code
Groupes
Projets
Afficher davantage de fils d'Ariane
Kubat
lektor
Requêtes de fusion
!142
Fixed: Move command
Code
Examiner les modifications
Extraire la branche
Télécharger
Correctifs
Diff brut
Étendre la barre latérale
Fusionnées
Fixed: Move command
move_command
vers
master
Vue d'ensemble
0
Validations
3
Pipelines
4
Modifications
2
Fusionnées
Deurstann
a demandé de fusionner
move_command
vers
master
Il y a 4 ans
Vue d'ensemble
0
Validations
3
Pipelines
4
Modifications
2
Fixed move command
0
0
Rapports de requête de fusion
Comparer
master
version 3
8ae62614
Il y a 4 ans
version 2
9cd6bb98
Il y a 4 ans
version 1
25212477
Il y a 4 ans
master (base)
et
dernière version
dernière version
ba4576da
3 validations,
Il y a 4 ans
version 3
8ae62614
4 validations,
Il y a 4 ans
version 2
9cd6bb98
4 validations,
Il y a 4 ans
version 1
25212477
3 validations,
Il y a 4 ans
2 files
+
124
−
24
Côte à côte
Comparer les modifications
Côte à côte
En ligne
Afficher les modifications des espaces
Afficher un fichier à la fois
Fichiers
2
src/database/queue.c
+
123
−
24
Afficher le fichier @ ba4576da
Modifier dans l'éditeur de fichier unique
Ouvrir dans Web EDI
Afficher le fichier complet
@@ -439,36 +439,135 @@ error:
@@ -439,36 +439,135 @@ error:
bool
bool
database_queue_move
(
volatile
sqlite3
*
db
,
int
from
,
int
to
)
database_queue_move
(
volatile
sqlite3
*
db
,
int
from
,
int
to
)
{
{
/* stmt arguments in order:
/* TODO: See if there is a solution with less lines of code */
* 1. to
* 2. to
* 3. from
*/
static
const
char
*
SQL_STMT
=
"BEGIN TRANSACTION;"
"UPDATE queue SET position = position + 1 WHERE position >= ?;"
"UPDATE queue SET position = ? WHERE position = ?;"
"COMMIT;"
;
sqlite3_stmt
*
stmt
=
0
;
bool
ret
=
false
;
int
code
;
SQLITE_PREPARE
(
db
,
stmt
,
SQL_STMT
,
error
);
static
const
char
*
SQL_TEMPLATE_toINFfrom
=
SQLITE_BIND_INT
(
db
,
stmt
,
1
,
to
,
error
);
/* Clean queue_tmp */
SQLITE_BIND_INT
(
db
,
stmt
,
2
,
to
,
error
);
"DELETE FROM queue_tmp;"
SQLITE_BIND_INT
(
db
,
stmt
,
3
,
from
,
error
);
"DELETE FROM sqlite_sequence WHERE name = 'queue_tmp';"
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
"WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION, kara_id, priority"
" FROM queue)"
"SELECT POSITION, kara_id, priority"
" FROM TEMP_TABLE WHERE POSITION < %d AND POSITION != %d ORDER BY POSITION;"
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
" VALUES(%d,("
" WITH TEMP_TABLE AS ("
" SELECT ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority FROM queue)"
" SELECT kara_id FROM TEMP_TABLE WHERE POSITION = %d"
" ),("
" WITH TEMP_TABLE AS ("
" SELECT ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority FROM queue)"
" SELECT priority FROM TEMP_TABLE WHERE POSITION = %d"
" ));"
;
static
const
char
*
SQL_TEMPLATE_toSUPfrom_Part1
=
/* Clean queue_tmp */
"DELETE FROM queue_tmp;"
"DELETE FROM sqlite_sequence WHERE name = 'queue_tmp';"
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
"WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION, kara_id, priority"
" FROM queue)"
"SELECT POSITION, kara_id, priority"
" FROM TEMP_TABLE WHERE POSITION < %d ORDER BY POSITION;"
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
"WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION, kara_id, priority"
" FROM queue)"
"SELECT POSITION - 1, kara_id, priority"
" FROM TEMP_TABLE WHERE POSITION > %d AND POSITION < %d ORDER BY POSITION;"
;
static
const
char
*
SQL_TEMPLATE_toSUPfrom_Part2
=
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
" VALUES(%d-1,("
" WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority FROM queue)"
" SELECT kara_id FROM TEMP_TABLE WHERE POSITION = %d"
" ),("
" WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority FROM queue)"
" SELECT priority FROM TEMP_TABLE WHERE POSITION ="
" CASE WHEN (SELECT COUNT(*) FROM TEMP_TABLE)>=%d THEN %d ELSE %d-1 END"
"));"
;
static
const
char
*
SQL_TEMPLATE_PART_2_toINFfrom
=
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
"WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority FROM queue)"
"SELECT (POSITION+1) , kara_id, priority"
" FROM TEMP_TABLE WHERE POSITION >= %d AND POSITION < %d ORDER BY POSITION;"
"INSERT INTO queue_tmp(position, kara_id,priority)"
" WITH TEMP_TABLE AS (SELECT"
" ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority"
" FROM queue)"
" SELECT POSITION , kara_id, priority"
" FROM TEMP_TABLE WHERE POSITION > %d AND POSITION >=%d ORDER BY POSITION;"
/* Clean queue and insert back */
"DELETE FROM queue;"
"DELETE FROM sqlite_sequence WHERE name = 'queue';"
"INSERT INTO queue(position, kara_id, priority)"
" SELECT position, kara_id, priority FROM queue_tmp ORDER BY priority, position;"
/* Clean queue_tmp */
"DELETE FROM sqlite_sequence WHERE name = 'queue_tmp';"
"DELETE FROM queue_tmp;"
;
static
const
char
*
SQL_TEMPLATE_PART_2_toSUPfrom
=
/* Construct queue */
"INSERT INTO queue_tmp(position, kara_id,priority)"
"WITH TEMP_TABLE AS ("
" SELECT ROW_NUMBER() OVER(ORDER BY priority DESC, position ASC) AS POSITION,"
" kara_id, priority FROM queue)"
"SELECT POSITION , kara_id, priority"
" FROM TEMP_TABLE WHERE POSITION >= %d AND POSITION != %d ORDER BY POSITION;"
/* Clean queue and insert back */
"DELETE FROM queue;"
"DELETE FROM sqlite_sequence WHERE name = 'queue';"
"INSERT INTO queue(position, kara_id, priority)"
" SELECT position, kara_id, priority FROM queue_tmp ORDER BY priority, position;"
/* Clean queue_tmp */
"DELETE FROM sqlite_sequence WHERE name = 'queue_tmp';"
"DELETE FROM queue_tmp;"
;
c
ode
=
sqlite3_step
(
stmt
)
;
c
har
SQL
[
LKT_MAX_SQLITE_STATEMENT
]
;
if
(
code
!=
SQLITE_ROW
&&
code
!=
SQLITE_DONE
&&
code
!=
SQLITE_OK
)
{
SQLITE_EXEC
(
db
,
"BEGIN TRANSACTION;"
,
error_no_rollback
);
LOG_ERROR
(
"DB"
,
"Move failed"
);
if
(
to
<
from
)
{
goto
error
;
safe_snprintf
(
SQL
,
LKT_MAX_SQLITE_STATEMENT
,
SQL_TEMPLATE_toINFfrom
,
to
,
from
,
to
,
from
,
to
);
SQLITE_EXEC
(
db
,
SQL
,
error
);
safe_snprintf
(
SQL
,
LKT_MAX_SQLITE_STATEMENT
,
SQL_TEMPLATE_PART_2_toINFfrom
,
to
,
from
,
from
,
to
);
SQLITE_EXEC
(
db
,
SQL
,
error
);
}
}
ret
=
true
;
else
{
safe_snprintf
(
SQL
,
LKT_MAX_SQLITE_STATEMENT
,
SQL_TEMPLATE_toSUPfrom_Part1
,
from
,
from
,
to
);
SQLITE_EXEC
(
db
,
SQL
,
error
);
safe_snprintf
(
SQL
,
LKT_MAX_SQLITE_STATEMENT
,
SQL_TEMPLATE_toSUPfrom_Part2
,
to
,
from
,
to
,
to
,
to
);
SQLITE_EXEC
(
db
,
SQL
,
error
);
safe_snprintf
(
SQL
,
LKT_MAX_SQLITE_STATEMENT
,
SQL_TEMPLATE_PART_2_toSUPfrom
,
to
,
from
,
from
,
to
);
SQLITE_EXEC
(
db
,
SQL
,
error
);
}
SQLITE_EXEC
(
db
,
"COMMIT;"
,
error
);
return
true
;
error:
error:
sqlite3_finalize
(
stmt
);
SQLITE_DO_ROLLBACK
(
db
);
return
ret
;
error_no_rollback:
return
false
;
}
}
bool
bool
Chargement en cours