Function act_create_database

src/gpre/sql.cpp:1687–1777

//

static act* act_create_database()
{
	bool dummy;

	if (gpreGlob.isc_databases && gpreGlob.isc_databases->dbb_next)
		PAR_error("CREATE DATABASE only allowed in context of a single database");

	if (!gpreGlob.isc_databases)
	{
		// generate a dummy db

		dummy = true;
		gpreGlob.isc_databases = (gpre_dbb*) MSC_alloc_permanent(DBB_LEN);

		// allocate symbol block

		gpre_sym* symbol = (gpre_sym*) MSC_alloc_permanent(SYM_LEN);

		// make it the default database

		symbol->sym_type = SYM_database;
		symbol->sym_object = (gpre_ctx*) gpreGlob.isc_databases;
		symbol->sym_string = gpreGlob.database_name;

		// database block points to the symbol block

		gpreGlob.isc_databases->dbb_name = symbol;
		gpreGlob.isc_databases->dbb_filename = NULL;
		gpreGlob.isc_databases->dbb_c_lc_ctype = gpreGlob.module_lc_ctype;
	}
	else
		dummy = false;

	// get database name

	gpre_dbb* db = NULL;
	if (isQuoted(gpreGlob.token_global.tok_type))
	{
		db = dup_dbb(gpreGlob.isc_databases);
		TEXT* string = (TEXT*) MSC_alloc(gpreGlob.token_global.tok_length + 1);
		db->dbb_filename = string;
		MSC_copy(gpreGlob.token_global.tok_string, gpreGlob.token_global.tok_length, string);
		if (!gpreGlob.isc_databases->dbb_filename)
			gpreGlob.isc_databases->dbb_filename = string;
		PAR_get_token();
	}
	else
		CPR_s_error("<quoted database name>");

	// Create a request for generating DYN to add files to database.

	//gpre_req* request = MSC_request (REQ_create_database);
	gpre_req* request = MSC_request(REQ_ddl);
	request->req_flags |= REQ_sql_database_dyn;
	request->req_database = db;

	// create action block