244 lines
4.7 KiB
Plaintext
244 lines
4.7 KiB
Plaintext
%{
|
|
/*-------------------------------------------------------------------------
|
|
*
|
|
* repl_scanner.l
|
|
* a lexical scanner for the replication commands
|
|
*
|
|
* Portions Copyright (c) 1996-2014, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
*
|
|
* IDENTIFICATION
|
|
* src/backend/replication/repl_scanner.l
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#include "postgres.h"
|
|
|
|
#include "utils/builtins.h"
|
|
#include "parser/scansup.h"
|
|
|
|
/* Avoid exit() on fatal scanner errors (a bit ugly -- see yy_fatal_error) */
|
|
#undef fprintf
|
|
#define fprintf(file, fmt, msg) fprintf_to_ereport(fmt, msg)
|
|
|
|
static void
|
|
fprintf_to_ereport(const char *fmt, const char *msg)
|
|
{
|
|
ereport(ERROR, (errmsg_internal("%s", msg)));
|
|
}
|
|
|
|
/* Handle to the buffer that the lexer uses internally */
|
|
static YY_BUFFER_STATE scanbufhandle;
|
|
|
|
static StringInfoData litbuf;
|
|
|
|
static void startlit(void);
|
|
static char *litbufdup(void);
|
|
static void addlit(char *ytext, int yleng);
|
|
static void addlitchar(unsigned char ychar);
|
|
|
|
%}
|
|
|
|
%option 8bit
|
|
%option never-interactive
|
|
%option nodefault
|
|
%option noinput
|
|
%option nounput
|
|
%option noyywrap
|
|
%option warn
|
|
%option prefix="replication_yy"
|
|
|
|
%x xq xd
|
|
|
|
/* Extended quote
|
|
* xqdouble implements embedded quote, ''''
|
|
*/
|
|
xqstart {quote}
|
|
xqdouble {quote}{quote}
|
|
xqinside [^']+
|
|
|
|
/* Double quote
|
|
* Allows embedded spaces and other special characters into identifiers.
|
|
*/
|
|
dquote \"
|
|
xdstart {dquote}
|
|
xdstop {dquote}
|
|
xddouble {dquote}{dquote}
|
|
xdinside [^"]+
|
|
|
|
digit [0-9]+
|
|
hexdigit [0-9A-Za-z]+
|
|
|
|
quote '
|
|
quotestop {quote}
|
|
|
|
ident_start [A-Za-z\200-\377_]
|
|
ident_cont [A-Za-z\200-\377_0-9\$]
|
|
|
|
identifier {ident_start}{ident_cont}*
|
|
|
|
%%
|
|
|
|
BASE_BACKUP { return K_BASE_BACKUP; }
|
|
FAST { return K_FAST; }
|
|
IDENTIFY_SYSTEM { return K_IDENTIFY_SYSTEM; }
|
|
LABEL { return K_LABEL; }
|
|
NOWAIT { return K_NOWAIT; }
|
|
PROGRESS { return K_PROGRESS; }
|
|
MAX_RATE { return K_MAX_RATE; }
|
|
WAL { return K_WAL; }
|
|
TIMELINE { return K_TIMELINE; }
|
|
START_REPLICATION { return K_START_REPLICATION; }
|
|
CREATE_REPLICATION_SLOT { return K_CREATE_REPLICATION_SLOT; }
|
|
DROP_REPLICATION_SLOT { return K_DROP_REPLICATION_SLOT; }
|
|
TIMELINE_HISTORY { return K_TIMELINE_HISTORY; }
|
|
PHYSICAL { return K_PHYSICAL; }
|
|
LOGICAL { return K_LOGICAL; }
|
|
SLOT { return K_SLOT; }
|
|
|
|
"," { return ','; }
|
|
";" { return ';'; }
|
|
"(" { return '('; }
|
|
")" { return ')'; }
|
|
|
|
[\n] ;
|
|
[\t] ;
|
|
" " ;
|
|
|
|
{digit}+ {
|
|
yylval.uintval = strtoul(yytext, NULL, 10);
|
|
return UCONST;
|
|
}
|
|
|
|
{hexdigit}+\/{hexdigit}+ {
|
|
uint32 hi,
|
|
lo;
|
|
if (sscanf(yytext, "%X/%X", &hi, &lo) != 2)
|
|
yyerror("invalid streaming start location");
|
|
yylval.recptr = ((uint64) hi) << 32 | lo;
|
|
return RECPTR;
|
|
}
|
|
|
|
{xqstart} {
|
|
BEGIN(xq);
|
|
startlit();
|
|
}
|
|
|
|
<xq>{quotestop} {
|
|
yyless(1);
|
|
BEGIN(INITIAL);
|
|
yylval.str = litbufdup();
|
|
return SCONST;
|
|
}
|
|
|
|
<xq>{xqdouble} {
|
|
addlitchar('\'');
|
|
}
|
|
|
|
<xq>{xqinside} {
|
|
addlit(yytext, yyleng);
|
|
}
|
|
|
|
{xdstart} {
|
|
BEGIN(xd);
|
|
startlit();
|
|
}
|
|
|
|
<xd>{xdstop} {
|
|
int len;
|
|
yyless(1);
|
|
BEGIN(INITIAL);
|
|
yylval.str = litbufdup();
|
|
len = strlen(yylval.str);
|
|
truncate_identifier(yylval.str, len, true);
|
|
return IDENT;
|
|
}
|
|
|
|
<xd>{xdinside} {
|
|
addlit(yytext, yyleng);
|
|
}
|
|
|
|
{identifier} {
|
|
int len = strlen(yytext);
|
|
|
|
yylval.str = downcase_truncate_identifier(yytext, len, true);
|
|
return IDENT;
|
|
}
|
|
|
|
<xq,xd><<EOF>> { yyerror("unterminated quoted string"); }
|
|
|
|
|
|
<<EOF>> {
|
|
yyterminate();
|
|
}
|
|
|
|
. {
|
|
ereport(ERROR,
|
|
(errcode(ERRCODE_SYNTAX_ERROR),
|
|
errmsg("syntax error: unexpected character \"%s\"", yytext)));
|
|
}
|
|
%%
|
|
|
|
|
|
static void
|
|
startlit(void)
|
|
{
|
|
initStringInfo(&litbuf);
|
|
}
|
|
|
|
static char *
|
|
litbufdup(void)
|
|
{
|
|
return litbuf.data;
|
|
}
|
|
|
|
static void
|
|
addlit(char *ytext, int yleng)
|
|
{
|
|
appendBinaryStringInfo(&litbuf, ytext, yleng);
|
|
}
|
|
|
|
static void
|
|
addlitchar(unsigned char ychar)
|
|
{
|
|
appendStringInfoChar(&litbuf, ychar);
|
|
}
|
|
|
|
void __attribute__((noreturn))
|
|
yyerror(const char *message)
|
|
{
|
|
ereport(ERROR,
|
|
(errcode(ERRCODE_SYNTAX_ERROR),
|
|
errmsg_internal("%s", message)));
|
|
}
|
|
|
|
|
|
void
|
|
replication_scanner_init(const char *str)
|
|
{
|
|
Size slen = strlen(str);
|
|
char *scanbuf;
|
|
|
|
/*
|
|
* Might be left over after ereport()
|
|
*/
|
|
if (YY_CURRENT_BUFFER)
|
|
yy_delete_buffer(YY_CURRENT_BUFFER);
|
|
|
|
/*
|
|
* Make a scan buffer with special termination needed by flex.
|
|
*/
|
|
scanbuf = (char *) palloc(slen + 2);
|
|
memcpy(scanbuf, str, slen);
|
|
scanbuf[slen] = scanbuf[slen + 1] = YY_END_OF_BUFFER_CHAR;
|
|
scanbufhandle = yy_scan_buffer(scanbuf, slen + 2);
|
|
}
|
|
|
|
void
|
|
replication_scanner_finish()
|
|
{
|
|
yy_delete_buffer(scanbufhandle);
|
|
scanbufhandle = NULL;
|
|
}
|