97 	return true;

    97 	return true;

    98 end

    98 end

    99 function engine:onconnect() -- luacheck: ignore 212/self

    99 function engine:onconnect() -- luacheck: ignore 212/self

   100 	-- Override from create_engine()

   100 	-- Override from create_engine()

   101 end

   101 end

   102 

   105 

   103 function engine:prepquery(sql)

   106 function engine:prepquery(sql)

   104 	if self.params.driver == "MySQL" then

   107 	if self.params.driver == "MySQL" then

   105 		sql = sql:gsub("\"", "`");

   108 		sql = sql:gsub("\"", "`");

   106 	end

   109 	end

   222 	if not ok then

   225 	if not ok then

   223 		local conn = self.conn;

   226 		local conn = self.conn;

   224 		if not conn or not conn:ping() then

   227 		if not conn or not conn:ping() then

   225 			log("debug", "Database connection was closed. Will reconnect and retry.");

   228 			log("debug", "Database connection was closed. Will reconnect and retry.");

   226 			self.conn = nil;

   229 			self.conn = nil;

   227 			log("debug", "Retrying SQL transaction [%s]", (...));

   231 			log("debug", "Retrying SQL transaction [%s]", (...));

   228 			ok, ret, b, c = self:_transaction(...);

   232 			ok, ret, b, c = self:_transaction(...);

   229 			log("debug", "SQL transaction retry %s", ok and "succeeded" or "failed");

   233 			log("debug", "SQL transaction retry %s", ok and "succeeded" or "failed");

   230 		else

   234 		else

   231 			log("debug", "SQL connection is up, so not retrying");

   235 			log("debug", "SQL connection is up, so not retrying");

   363 		port = params.port,

   367 		port = params.port,

   364 		path = params.database,

   368 		path = params.database,

   365 	};

   369 	};

   366 end

   370 end

   367 

   371 

   370 end

   374 end

   371 

   375 

   372 return {

   376 return {

   373 	is_column = is_column;

   377 	is_column = is_column;

   374 	is_index = is_index;

   378 	is_index = is_index;