Function SrcColumns

storage/connect/myconn.cpp:394–436

/ SrcColumns: constructs the result blocks containing all columns */ resulting from an SQL source definition query execution. */ /

/*  resulting from an SQL source definition query execution.            */
/************************************************************************/
PQRYRES SrcColumns(PGLOBAL g, const char *host, const char *db,
                   const char *user, const char *pwd,
                   const char *srcdef, int port)
  {
  char   *query;
  int     w;
  MYSQLC  myc;
  PQRYRES qrp = NULL;
  const char *p;

  if (!port)
    port = mysqld_port;

	if (!strnicmp(srcdef, "select ", 7) || strstr(srcdef, "%s")) {
		size_t query_sz = strlen(srcdef) + 10;
		query = (char *)PlugSubAlloc(g, NULL, query_sz);

		if ((p= strstr(srcdef, "%s")))
		{
			/* Replace %s with 1=1 */
			snprintf(query, query_sz, "%.*s1=1%s",
			         (int) (p - srcdef), srcdef, p + 2); // dummy where clause
		}
		else
			safe_strcpy(query, query_sz, srcdef);

		if (!strnicmp(srcdef, "select ", 7))
			safe_strcat(query, query_sz, " LIMIT 0");

	} else
    query = (char *)srcdef;

  // Open a MySQL connection for this table
  if (myc.Open(g, host, db, user, pwd, port))
    return NULL;

  // Send the source command to MySQL
  if (myc.ExecSQL(g, query, &w) == RC_OK)
    qrp = myc.GetResult(g, true);

  myc.Close();
  return qrp;
  } // end of SrcColumns

/* -------------------------- Class MYSQLC --------------------------- */