Method execute_ddl

src/query/executor.rs:1828–2217

(
        framed: &mut Framed<T, crate::protocol::PostgresCodec>,
        db: &Arc<DbHandler>,
        session: &Arc<SessionState>,
        query: &str,
        _query_router: Option<&Arc<QueryRouter>

    }
    
    async fn execute_ddl<T>(
        framed: &mut Framed<T, crate::protocol::PostgresCodec>,
        db: &Arc<DbHandler>,
        session: &Arc<SessionState>,
        query: &str,
        _query_router: Option<&Arc<QueryRouter>>,
    ) -> Result<(), PgSqliteError>
    where
        T: tokio::io::AsyncRead + tokio::io::AsyncWrite + Unpin + Send,
    {
        use crate::translator::CreateTableTranslator;
        use crate::query::{QueryTypeDetector, QueryType};
        use crate::ddl::EnumDdlHandler;
        use tracing::info;

        // Check if this is a CREATE DATABASE statement
        if matches!(QueryTypeDetector::detect_query_type(query), QueryType::Create) &&
           query.trim_start()[6..].trim_start().to_uppercase().starts_with("DATABASE") {
            info!("CREATE DATABASE command received - SQLite doesn't have database concept, succeeding with no-op");

            // Send command complete
            framed.send(BackendMessage::CommandComplete {
                tag: "CREATE DATABASE".to_string()
            }).await
                .map_err(PgSqliteError::Io)?;

            return Ok(());
        }

        // Check if this is a DROP DATABASE statement
        if matches!(QueryTypeDetector::detect_query_type(query), QueryType::Drop) &&
           query.trim_start()[4..].trim_start().to_uppercase().starts_with("DATABASE") {
            info!("DROP DATABASE command received - SQLite doesn't have database concept, succeeding with no-op");

            // Send command complete
            framed.send(BackendMessage::CommandComplete {
                tag: "DROP DATABASE".to_string()
            }).await
                .map_err(PgSqliteError::Io)?;

            return Ok(());
        }

        // Check if this is a CREATE USER/ROLE statement
        if matches!(QueryTypeDetector::detect_query_type(query), QueryType::Create) {
            let after_create = query.trim_start()[6..].trim_start().to_uppercase();
            if after_create.starts_with("USER") || after_create.starts_with("ROLE") {
                info!("CREATE USER/ROLE command received - SQLite doesn't have user management, succeeding with no-op");

                let tag = if after_create.starts_with("USER") { "CREATE USER" } else { "CREATE ROLE" };
                framed.send(BackendMessage::CommandComplete {
                    tag: tag.to_string()
                }).await
                    .map_err(PgSqliteError::Io)?;

                return Ok(());
            }
        }