use {
	crate::{data::Schema, Column, ComplexTableName, CreateError, Error, Glue, Result},
	sqlparser::ast::{ColumnDef, ObjectName},
};

impl Glue {
	pub async fn create_table(
		&mut self,
		name: &ObjectName,
		column_defs: &[ColumnDef],
		if_not_exists: bool,
	) -> Result<()> {
		let ComplexTableName {
			name: table_name,
			database,
			..
		} = name.try_into()?;

		let schema = Schema {
			table_name,
			column_defs: column_defs.iter().cloned().map(Column::from).collect(),
			indexes: vec![],
		};
		self.add_table(database, schema, if_not_exists).await
	}
	pub async fn add_table(
		&mut self,
		database: Option<String>,
		schema: Schema,
		if_not_exists: bool,
	) -> Result<()> {
		let database = &mut **self.get_mut_database(&database)?;
		if database.fetch_schema(&schema.table_name).await?.is_some() {
			if !if_not_exists {
				Err(Error::Create(CreateError::AlreadyExists(
					schema.table_name.to_owned(),
				)))
			} else {
				Ok(())
			}
		} else {
			database.insert_schema(&schema).await
		}
	}
}