diff --git a/src-tauri/src/database/mysql.rs b/src-tauri/src/database/mysql.rs
index 12a9199..9d1019c 100644
--- a/src-tauri/src/database/mysql.rs
+++ b/src-tauri/src/database/mysql.rs
@@ -127,6 +127,43 @@ impl ConnectionPool for MySQLPool {
     }
 }
 
+/// Try to read a column value as String, falling back to UTF-8 decoded bytes
+/// if the direct String conversion fails. This handles cases where mysql_async's
+/// `FromValue<String>` fails on certain INFORMATION_SCHEMA virtual table columns
+/// due to charset/collation differences between the virtual table encoding
+/// and the connection's character set.
+fn get_str(row: &Row, idx: usize) -> String {
+    row.get_opt::<String, _>(idx)
+        .and_then(|r| r.ok())
+        .or_else(|| {
+            row.get_opt::<Vec<u8>, _>(idx)
+                .and_then(|r| r.ok())
+                .map(|b| String::from_utf8_lossy(&b).to_string())
+        })
+        .unwrap_or_default()
+}
+
+fn get_str_by_name(row: &Row, name: &str) -> String {
+    row.get_opt::<String, _>(name)
+        .and_then(|r| r.ok())
+        .or_else(|| {
+            row.get_opt::<Vec<u8>, _>(name)
+                .and_then(|r| r.ok())
+                .map(|b| String::from_utf8_lossy(&b).to_string())
+        })
+        .unwrap_or_default()
+}
+
+fn get_opt_str(row: &Row, idx: usize) -> Option<String> {
+    row.get_opt::<String, _>(idx)
+        .and_then(|r| r.ok())
+        .or_else(|| {
+            row.get_opt::<Vec<u8>, _>(idx)
+                .and_then(|r| r.ok())
+                .map(|b| String::from_utf8_lossy(&b).to_string())
+        })
+}
+
 /// MySQL database adapter.
 pub struct MySQLAdapter {
     pub(crate) config: ConnectionConfig,
@@ -672,21 +709,18 @@ impl DatabaseAdapter for MySQLAdapter {
         let columns = rows
             .into_iter()
             .map(|row| {
-                let name: String = row.get_opt(0).and_then(|r| r.ok()).unwrap_or_default();
-                let data_type: String = row.get_opt(1).and_then(|r| r.ok()).unwrap_or_default();
-                let is_nullable: String = row
-                    .get_opt(2)
-                    .and_then(|r| r.ok())
-                    .unwrap_or_else(|| "YES".to_string());
-                let default_value: Option<String> = row.get_opt(3).and_then(|r| r.ok()).flatten();
+                let name: String = get_str(&row, 0);
+                let data_type: String = get_str(&row, 1);
+                let is_nullable: String = get_str(&row, 2);
+                let default_value: Option<String> = get_opt_str(&row, 3);
                 let max_length: Option<u32> = row.get_opt(4).and_then(|r| r.ok()).flatten();
                 let precision: Option<u32> = row.get_opt(5).and_then(|r| r.ok()).flatten();
                 let scale: Option<u32> = row.get_opt(6).and_then(|r| r.ok()).flatten();
-                let column_key: String = row.get_opt(7).and_then(|r| r.ok()).unwrap_or_default();
-                let extra: String = row.get_opt(8).and_then(|r| r.ok()).unwrap_or_default();
-                let description: Option<String> = row.get_opt(9).and_then(|r| r.ok()).flatten();
+                let column_key: String = get_str_by_name(&row, "COLUMN_KEY");
+                let extra: String = get_str(&row, 8);
+                let description: Option<String> = get_opt_str(&row, 9);
 
-                let is_primary_key = column_key.to_uppercase().contains("PRI");
+                let is_primary_key = column_key.eq_ignore_ascii_case("PRI");
                 let is_auto_increment = extra.to_uppercase().contains("AUTO_INCREMENT");
 
                 ColumnInfo {
diff --git a/src/components/database-browser/DataTableView.vue b/src/components/database-browser/DataTableView.vue
index 9b2ac80..6dd8ee2 100644
--- a/src/components/database-browser/DataTableView.vue
+++ b/src/components/database-browser/DataTableView.vue
@@ -183,12 +183,16 @@ const pkColumns = computed(() =>
 )
 
 function extractPkValues(row: Record<string, unknown>): Record<string, unknown> {
-  return Object.fromEntries(pkColumns.value.map((col: string) => [col, row[col] ?? null]))
+  const cols = pkColumns.value.length > 0 ? pkColumns.value : (data.value?.columns ?? [])
+  return Object.fromEntries(cols.map((col: string) => [col, row[col] ?? null]))
 }
 
 function formatPkSummary(row: Record<string, unknown>): string {
-  return pkColumns.value.length > 0
-    ? pkColumns.value.map((col: string) => `${col}: ${formatTableValue(row[col])}`).join(', ')
+  const cols = pkColumns.value.length > 0
+    ? pkColumns.value
+    : (data.value?.columns ?? []).slice(0, 3)
+  return cols.length > 0
+    ? cols.map((col: string) => `${col}: ${formatTableValue(row[col])}`).join(', ')
     : Object.entries(row).slice(0, 2).map(([k, v]) => `${k}: ${formatTableValue(v)}`).join(', ')
 }
 
@@ -323,15 +327,15 @@ async function fetchColumnInfo() {
     return
   }
   try {
-    columnInfoList.value = await invoke<ColumnTypeInfo[]>('list_columns', {
+    const result = await invoke<ColumnTypeInfo[]>('list_columns', {
       connectionId: props.connectionId,
       database: props.database,
       schema: props.schema ?? null,
       tableName: props.tableName,
     })
+    columnInfoList.value = result
   }
-  catch (err) {
-    console.error('Failed to fetch column info:', err)
+  catch {
     columnInfoList.value = []
   }
 }
@@ -512,9 +516,8 @@ async function exportCSV() {
 function openDeleteDialog(row: Record<string, unknown>) {
   if (pkColumns.value.length === 0) {
     toast.warning(t('components.dataTableView.notifications.noPrimaryKey'), {
-      description: t('components.dataTableView.notifications.noPrimaryKeyDesc'),
+      description: t('components.dataTableView.notifications.fallbackAllColumns'),
     })
-    return
   }
   deletingRow.value = row
   deleteDialogOpen.value = true
@@ -603,9 +606,8 @@ function rawValueToString(v: unknown): string {
 function openEditDialog(row: Record<string, unknown>) {
   if (pkColumns.value.length === 0) {
     toast.warning(t('components.dataTableView.notifications.noPrimaryKey'), {
-      description: t('components.dataTableView.notifications.noPrimaryKeyDesc'),
+      description: t('components.dataTableView.notifications.fallbackAllColumns'),
     })
-    return
   }
   editingRow.value = row
   editErrors.value = {}
@@ -946,7 +948,7 @@ watch(
 
         <!-- Delete Selected button -->
         <Button
-          v-if="selectedRows.size > 0 && pkColumns.length > 0"
+          v-if="selectedRows.size > 0"
           variant="destructive"
           size="sm"
           class="text-xs flex-shrink-0 h-7"
@@ -1045,16 +1047,16 @@ watch(
         >
           <thead>
             <tr class="border-b">
-              <th v-if="pkColumns.length > 0" class="data-table-header text-center w-10">
-                <input
-                  type="checkbox"
-                  class="h-3 w-3 cursor-pointer"
-                  :checked="allRowsSelected"
-                  @change="toggleSelectAll"
-                >
-              </th>
-              <th class="data-table-header text-center w-10">
-                #
+              <th class="data-table-header text-center w-16">
+                <div class="flex gap-1 items-center justify-center">
+                  <input
+                    type="checkbox"
+                    class="h-3 w-3 cursor-pointer"
+                    :checked="allRowsSelected"
+                    @change="toggleSelectAll"
+                  >
+                  <span class="text-xs text-muted-foreground font-normal">#</span>
+                </div>
               </th>
               <th
                 v-for="col in visibleColumns"
@@ -1080,16 +1082,16 @@ watch(
               class="border-b hover:bg-muted/50"
               :class="{ 'bg-muted/30': selectedRows.has(i) }"
             >
-              <td v-if="pkColumns.length > 0" class="text-xs px-3 py-1.5 text-center w-10">
-                <input
-                  type="checkbox"
-                  class="h-3 w-3 cursor-pointer"
-                  :checked="selectedRows.has(i)"
-                  @change="toggleRowSelection(i)"
-                >
-              </td>
-              <td class="text-xs text-muted-foreground px-3 py-1.5 text-center w-10">
-                {{ offset + i + 1 }}
+              <td class="text-xs px-2 py-1.5 text-center w-16">
+                <div class="flex gap-1 items-center justify-center">
+                  <input
+                    type="checkbox"
+                    class="h-3 w-3 cursor-pointer"
+                    :checked="selectedRows.has(i)"
+                    @change="toggleRowSelection(i)"
+                  >
+                  <span class="text-muted-foreground tabular-nums">{{ offset + i + 1 }}</span>
+                </div>
               </td>
               <td
                 v-for="col in visibleColumns"
@@ -1107,7 +1109,7 @@ watch(
                   <Button
                     variant="ghost"
                     size="icon"
-                    class="text-foreground h-6 w-6"
+                    class="text-blue-600 h-6 w-6 dark:text-blue-400"
                     :title="t('components.dataTableView.editRow')"
                     @click.stop="openEditDialog(row)"
                   >
@@ -1117,7 +1119,7 @@ watch(
                   <Button
                     variant="ghost"
                     size="icon"
-                    class="text-foreground h-6 w-6 hover:text-destructive"
+                    class="text-rose-500 h-6 w-6 dark:text-rose-400 hover:text-red-600 dark:hover:text-red-400"
                     :title="t('components.dataTableView.deleteRow')"
                     @click.stop="openDeleteDialog(row)"
                   >
@@ -1400,7 +1402,7 @@ watch(
 
 /* In body rows the actions cell background should match the row hover state */
 tr:hover .data-table-actions-col {
-  background-color: hsl(var(--muted) / 0.5);
+  background-color: hsl(var(--muted));
 }
 
 .col-header-cell {
diff --git a/src/components/sidebar/CreateDatabaseDialog.vue b/src/components/sidebar/CreateDatabaseDialog.vue
new file mode 100644
index 0000000..dabad29
--- /dev/null
+++ b/src/components/sidebar/CreateDatabaseDialog.vue
@@ -0,0 +1,212 @@
+<script setup lang="ts">
+import { computed, ref, watch } from 'vue'
+import { useI18n } from 'vue-i18n'
+import { Button } from '@/components/ui/button'
+import {
+  Dialog,
+  DialogContent,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from '@/components/ui/dialog'
+import { Input } from '@/components/ui/input'
+import { Label } from '@/components/ui/label'
+import {
+  Select,
+  SelectContent,
+  SelectItem,
+  SelectTrigger,
+  SelectValue,
+} from '@/components/ui/select'
+import { DatabaseType } from '@/store/connectionStore'
+
+const props = withDefaults(defineProps<Props>(), {
+  databaseType: undefined,
+})
+
+const emit = defineEmits<{
+  (e: 'update:open', value: boolean): void
+  (e: 'confirm', name: string, options: { charset?: string, collation?: string, encoding?: string, locale?: string }): void
+}>()
+
+const MYSQL_CHARSETS = [
+  'utf8mb4',
+  'utf8mb3',
+  'utf16',
+  'utf32',
+  'latin1',
+  'latin2',
+  'ascii',
+  'binary',
+  'cp1251',
+  'cp1257',
+  'big5',
+  'gbk',
+]
+
+const PG_ENCODINGS = ['UTF8', 'LATIN1', 'LATIN2', 'LATIN3', 'LATIN4', 'SQL_ASCII', 'BIG5', 'EUC_JP', 'EUC_KR', 'GB18030', 'GBK', 'ISO_8859_5', 'ISO_8859_13', 'ISO_8859_15', 'KOI8R', 'KOI8U', 'UNICODE', 'WIN1250', 'WIN1251', 'WIN1252', 'WIN866']
+
+const MYSQL_COMPAT = new Set<DatabaseType>([
+  DatabaseType.MYSQL,
+  DatabaseType.MARIADB,
+  DatabaseType.TIDB,
+  DatabaseType.OCEANBASE,
+  DatabaseType.TDSQL,
+  DatabaseType.POLARDB,
+  DatabaseType.DORIS,
+  DatabaseType.SELECTDB,
+  DatabaseType.STARROCKS,
+  DatabaseType.DATABEND,
+  DatabaseType.GOLDENDB,
+  DatabaseType.MANTICORESEARCH,
+  DatabaseType.SINGLESTOREMEMSQL,
+  DatabaseType.CLOUDSQLMYSQL,
+])
+
+const PG_COMPAT = new Set<DatabaseType>([
+  DatabaseType.POSTGRESQL,
+  DatabaseType.COCKROACHDB,
+  DatabaseType.REDSHIFT,
+  DatabaseType.YUGABYTEDB,
+  DatabaseType.TIMESCALEDB,
+  DatabaseType.KINGBASEES,
+  DatabaseType.GAUSSDB,
+  DatabaseType.HIGHGO,
+  DatabaseType.UXDB,
+  DatabaseType.OPENGAUSS,
+  DatabaseType.GBASE8C,
+  DatabaseType.QUESTDB,
+  DatabaseType.VASTBASE,
+  DatabaseType.YASHANDB,
+  DatabaseType.GREENPLUM,
+  DatabaseType.ENTERPRISEDB,
+  DatabaseType.CRATEDB,
+  DatabaseType.MATERIALIZE,
+  DatabaseType.ALLOYDB,
+  DatabaseType.CLOUDSQLPG,
+  DatabaseType.FUJITSUPG,
+])
+
+type Props = {
+  open: boolean
+  databaseType?: DatabaseType
+}
+
+const { t } = useI18n()
+
+const objectName = ref('')
+const charset = ref('')
+const collation = ref('')
+const encoding = ref('')
+const locale = ref('')
+
+const hasCharset = computed(() => props.databaseType && MYSQL_COMPAT.has(props.databaseType))
+const hasCollation = computed(() => props.databaseType && MYSQL_COMPAT.has(props.databaseType))
+const hasEncoding = computed(() => props.databaseType && PG_COMPAT.has(props.databaseType))
+const hasLocale = computed(() => props.databaseType && PG_COMPAT.has(props.databaseType))
+
+watch(() => props.open, (open) => {
+  if (open) {
+    objectName.value = ''
+    charset.value = 'utf8mb4'
+    collation.value = ''
+    encoding.value = 'UTF8'
+    locale.value = ''
+  }
+})
+
+function handleConfirm() {
+  const trimmed = objectName.value.trim()
+  if (!trimmed)
+    return
+  emit('confirm', trimmed, {
+    charset: hasCharset.value ? charset.value || undefined : undefined,
+    collation: hasCollation.value ? collation.value || undefined : undefined,
+    encoding: hasEncoding.value ? encoding.value || undefined : undefined,
+    locale: hasLocale.value ? locale.value || undefined : undefined,
+  })
+}
+</script>
+
+<template>
+  <Dialog :open="open" @update:open="(v: boolean) => emit('update:open', v)">
+    <DialogContent class="sm:max-w-[420px]">
+      <DialogHeader>
+        <DialogTitle>{{ t('sidebar.databases.actions.createDatabase.title') }}</DialogTitle>
+      </DialogHeader>
+
+      <div class="space-y-3">
+        <div class="space-y-1.5">
+          <Label class="text-xs">{{ t('sidebar.databases.actions.createDatabase.name') }} <span class="text-destructive">*</span></Label>
+          <Input
+            v-model="objectName"
+            :placeholder="t('sidebar.databases.actions.createDatabase.namePlaceholder')"
+            class="text-xs"
+            @keydown.enter="handleConfirm"
+          />
+        </div>
+
+        <!-- MySQL options -->
+        <template v-if="hasCharset">
+          <div class="space-y-1.5">
+            <Label class="text-xs">{{ t('sidebar.databases.actions.createDatabase.charset') }} <span class="text-muted-foreground font-normal">({{ t('sidebar.databases.actions.createDatabase.optional') }})</span></Label>
+            <Select v-model="charset">
+              <SelectTrigger class="text-xs h-8">
+                <SelectValue />
+              </SelectTrigger>
+              <SelectContent>
+                <SelectItem v-for="cs in MYSQL_CHARSETS" :key="cs" :value="cs" class="text-xs">
+                  {{ cs }}
+                </SelectItem>
+              </SelectContent>
+            </Select>
+          </div>
+          <div class="space-y-1.5">
+            <Label class="text-xs">{{ t('sidebar.databases.actions.createDatabase.collation') }} <span class="text-muted-foreground font-normal">({{ t('sidebar.databases.actions.createDatabase.optional') }})</span></Label>
+            <Input
+              v-model="collation"
+              :placeholder="t('sidebar.databases.actions.createDatabase.collationPlaceholder')"
+              class="text-xs"
+              @keydown.enter="handleConfirm"
+            />
+          </div>
+        </template>
+
+        <!-- PostgreSQL options -->
+        <template v-if="hasEncoding">
+          <div class="space-y-1.5">
+            <Label class="text-xs">{{ t('sidebar.databases.actions.createDatabase.encoding') }} <span class="text-muted-foreground font-normal">({{ t('sidebar.databases.actions.createDatabase.optional') }})</span></Label>
+            <Select v-model="encoding">
+              <SelectTrigger class="text-xs h-8">
+                <SelectValue />
+              </SelectTrigger>
+              <SelectContent>
+                <SelectItem v-for="enc in PG_ENCODINGS" :key="enc" :value="enc" class="text-xs">
+                  {{ enc }}
+                </SelectItem>
+              </SelectContent>
+            </Select>
+          </div>
+          <div class="space-y-1.5">
+            <Label class="text-xs">{{ t('sidebar.databases.actions.createDatabase.locale') }} <span class="text-muted-foreground font-normal">({{ t('sidebar.databases.actions.createDatabase.optional') }})</span></Label>
+            <Input
+              v-model="locale"
+              :placeholder="t('sidebar.databases.actions.createDatabase.localePlaceholder')"
+              class="text-xs"
+              @keydown.enter="handleConfirm"
+            />
+          </div>
+        </template>
+      </div>
+
+      <DialogFooter>
+        <Button variant="outline" size="sm" @click="emit('update:open', false)">
+          {{ t('sidebar.databases.actions.createDatabase.cancel') }}
+        </Button>
+        <Button size="sm" :disabled="!objectName.trim()" @click="handleConfirm">
+          {{ t('sidebar.databases.actions.createDatabase.confirm') }}
+        </Button>
+      </DialogFooter>
+    </DialogContent>
+  </Dialog>
+</template>
diff --git a/src/components/sidebar/CreateObjectDialog.vue b/src/components/sidebar/CreateObjectDialog.vue
new file mode 100644
index 0000000..a72cb28
--- /dev/null
+++ b/src/components/sidebar/CreateObjectDialog.vue
@@ -0,0 +1,75 @@
+<script setup lang="ts">
+import { ref, watch } from 'vue'
+import { useI18n } from 'vue-i18n'
+import { Button } from '@/components/ui/button'
+import {
+  Dialog,
+  DialogContent,
+  DialogDescription,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from '@/components/ui/dialog'
+import { Input } from '@/components/ui/input'
+
+type Props = {
+  open: boolean
+  /** Object type label — 'database', 'schema', or custom */
+  objectType: string
+  /** Optional placeholder for the name input */
+  placeholder?: string
+  /** Optional description text */
+  description?: string
+}
+
+const props = withDefaults(defineProps<Props>(), {
+  placeholder: '',
+  description: '',
+})
+
+const emit = defineEmits<{
+  (e: 'update:open', value: boolean): void
+  (e: 'confirm', name: string): void
+}>()
+
+const { t } = useI18n()
+const objectName = ref('')
+
+watch(() => props.open, (open) => {
+  if (open)
+    objectName.value = ''
+})
+
+function handleConfirm() {
+  const trimmed = objectName.value.trim()
+  if (trimmed)
+    emit('confirm', trimmed)
+}
+</script>
+
+<template>
+  <Dialog :open="open" @update:open="(v: boolean) => emit('update:open', v)">
+    <DialogContent class="sm:max-w-[400px]">
+      <DialogHeader>
+        <DialogTitle>{{ t('sidebar.databases.actions.createObject.title', { type: objectType }) }}</DialogTitle>
+        <DialogDescription v-if="description">
+          {{ description }}
+        </DialogDescription>
+      </DialogHeader>
+      <Input
+        v-model="objectName"
+        :placeholder="placeholder || t('sidebar.databases.actions.createObject.placeholder', { type: objectType })"
+        class="text-xs"
+        @keydown.enter="handleConfirm"
+      />
+      <DialogFooter>
+        <Button variant="outline" size="sm" @click="emit('update:open', false)">
+          {{ t('sidebar.databases.actions.createObject.cancel') }}
+        </Button>
+        <Button size="sm" :disabled="!objectName.trim()" @click="handleConfirm">
+          {{ t('sidebar.databases.actions.createObject.confirm') }}
+        </Button>
+      </DialogFooter>
+    </DialogContent>
+  </Dialog>
+</template>
diff --git a/src/components/sidebar/CreateTableDialog.vue b/src/components/sidebar/CreateTableDialog.vue
new file mode 100644
index 0000000..877742a
--- /dev/null
+++ b/src/components/sidebar/CreateTableDialog.vue
@@ -0,0 +1,340 @@
+<script setup lang="ts">
+import { computed, ref, watch } from 'vue'
+import { useI18n } from 'vue-i18n'
+import { Button } from '@/components/ui/button'
+import {
+  Dialog,
+  DialogContent,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from '@/components/ui/dialog'
+import { Input } from '@/components/ui/input'
+import { Label } from '@/components/ui/label'
+import { DatabaseType } from '@/store/connectionStore'
+
+type ColumnDef = {
+  id: number
+  name: string
+  type: string
+  length: string
+  nullable: boolean
+  defaultValue: string
+  autoIncrement: boolean
+  primaryKey: boolean
+}
+
+type Props = {
+  open: boolean
+  /** Current database context */
+  database: string | null
+  /** Optional schema context */
+  schema?: string | null
+  /** Database type for engine/options */
+  databaseType?: DatabaseType
+}
+
+const props = withDefaults(defineProps<Props>(), {
+  schema: null,
+  databaseType: undefined,
+})
+
+const emit = defineEmits<{
+  (e: 'update:open', value: boolean): void
+  (e: 'create', tableName: string, sql: string): void
+}>()
+
+const { t } = useI18n()
+
+const MYSQL_COMPAT = new Set<DatabaseType>([
+  DatabaseType.MYSQL,
+  DatabaseType.MARIADB,
+  DatabaseType.TIDB,
+  DatabaseType.OCEANBASE,
+  DatabaseType.TDSQL,
+  DatabaseType.POLARDB,
+  DatabaseType.DORIS,
+  DatabaseType.SELECTDB,
+  DatabaseType.STARROCKS,
+  DatabaseType.DATABEND,
+  DatabaseType.GOLDENDB,
+  DatabaseType.MANTICORESEARCH,
+  DatabaseType.SINGLESTOREMEMSQL,
+  DatabaseType.CLOUDSQLMYSQL,
+])
+
+const MYSQL_ENGINES = ['InnoDB', 'MyISAM', 'MEMORY', 'CSV', 'ARCHIVE', 'BLACKHOLE']
+
+const isMySQL = computed(() => props.databaseType && MYSQL_COMPAT.has(props.databaseType))
+
+const COMMON_TYPES = [
+  'INTEGER',
+  'BIGINT',
+  'SMALLINT',
+  'TINYINT',
+  'SERIAL',
+  'BIGSERIAL',
+  'VARCHAR',
+  'CHAR',
+  'TEXT',
+  'CLOB',
+  'BOOLEAN',
+  'FLOAT',
+  'DOUBLE',
+  'DECIMAL',
+  'NUMERIC',
+  'REAL',
+  'DATE',
+  'TIME',
+  'TIMESTAMP',
+  'TIMESTAMPTZ',
+  'BLOB',
+  'BYTEA',
+  'UUID',
+  'JSON',
+  'JSONB',
+  'ENUM',
+  'ARRAY',
+]
+
+const tableName = ref('')
+const tableEngine = ref('InnoDB')
+const columns = ref<ColumnDef[]>([])
+let nextColId = 1
+
+watch(() => props.open, (open) => {
+  if (open) {
+    tableName.value = ''
+    tableEngine.value = 'InnoDB'
+    columns.value = []
+    nextColId = 1
+    addColumn()
+  }
+})
+
+function addColumn() {
+  columns.value = [
+    ...columns.value,
+    { id: nextColId++, name: '', type: 'VARCHAR', length: '255', nullable: true, defaultValue: '', autoIncrement: false, primaryKey: false },
+  ]
+}
+
+function removeColumn(id: number) {
+  if (columns.value.length <= 1)
+    return
+  columns.value = columns.value.filter(c => c.id !== id)
+}
+
+function moveColumn(fromIndex: number, direction: -1 | 1) {
+  const toIndex = fromIndex + direction
+  if (toIndex < 0 || toIndex >= columns.value.length)
+    return
+  const arr = [...columns.value];
+  [arr[fromIndex], arr[toIndex]] = [arr[toIndex], arr[fromIndex]]
+  columns.value = arr
+}
+
+const ddlPreview = computed(() => {
+  if (!tableName.value.trim())
+    return ''
+
+  const name = tableName.value.trim()
+  const schemaPrefix = props.schema ? `${props.schema}.` : ''
+  const fullName = `${schemaPrefix}${name}`
+
+  const colLines = columns.value
+    .filter(c => c.name.trim())
+    .map((c) => {
+      let colDef = `  ${c.name.trim()} ${c.type}`
+      if (c.length && ['VARCHAR', 'CHAR', 'DECIMAL', 'NUMERIC'].includes(c.type))
+        colDef += `(${c.length})`
+      if (c.autoIncrement && ['INTEGER', 'BIGINT', 'SMALLINT'].includes(c.type))
+        colDef += ' GENERATED ALWAYS AS IDENTITY'
+      if (!c.nullable)
+        colDef += ' NOT NULL'
+      if (c.defaultValue)
+        colDef += ` DEFAULT ${c.defaultValue}`
+      return colDef
+    })
+
+  const pkCols = columns.value.filter(c => c.primaryKey && c.name.trim()).map(c => c.name.trim())
+  if (pkCols.length > 0)
+    colLines.push(`  PRIMARY KEY (${pkCols.join(', ')})`)
+
+  let ddl = `CREATE TABLE ${fullName} (\n${colLines.join(',\n')}\n)`
+  if (isMySQL.value)
+    ddl += ` ENGINE=${tableEngine.value}`
+  ddl += ';'
+
+  return ddl
+})
+
+function handleCreate() {
+  if (!tableName.value.trim() || !columns.value.some(c => c.name.trim()))
+    return
+  emit('create', tableName.value.trim(), ddlPreview.value)
+}
+</script>
+
+<template>
+  <Dialog :open="open" @update:open="(v: boolean) => emit('update:open', v)">
+    <DialogContent class="max-h-[85vh] overflow-y-auto sm:max-w-[700px]">
+      <DialogHeader>
+        <DialogTitle>{{ t('sidebar.databases.actions.createTable.title') }}</DialogTitle>
+      </DialogHeader>
+
+      <div class="space-y-4">
+        <!-- Table name + Engine for MySQL -->
+        <div class="flex gap-2 items-center">
+          <Label class="text-xs shrink-0 w-24">{{ t('sidebar.databases.actions.createTable.tableName') }}</Label>
+          <Input v-model="tableName" :placeholder="t('sidebar.databases.actions.createTable.tableNamePlaceholder')" class="text-xs flex-1" />
+          <template v-if="isMySQL">
+            <Label class="text-xs shrink-0">{{ t('sidebar.databases.actions.createTable.engine') }}</Label>
+            <select
+              v-model="tableEngine"
+              class="text-xs px-2 border border-input rounded-md bg-background h-7 w-24"
+            >
+              <option v-for="eng in MYSQL_ENGINES" :key="eng" :value="eng">
+                {{ eng }}
+              </option>
+            </select>
+          </template>
+        </div>
+
+        <!-- Column grid -->
+        <div class="space-y-1">
+          <div class="flex items-center justify-between">
+            <Label class="text-xs font-medium">{{ t('sidebar.databases.actions.createTable.columns') }}</Label>
+            <Button variant="outline" size="sm" class="text-xs h-6" @click="addColumn">
+              + {{ t('sidebar.databases.actions.createTable.addColumn') }}
+            </Button>
+          </div>
+
+          <!-- Header row -->
+          <div class="text-xs text-muted-foreground font-medium px-1 py-0.5 gap-1 grid grid-cols-12">
+            <span class="col-span-1" />
+            <span class="col-span-2">{{ t('sidebar.databases.actions.createTable.colName') }}</span>
+            <span class="col-span-2">{{ t('sidebar.databases.actions.createTable.colType') }}</span>
+            <span class="col-span-1">{{ t('sidebar.databases.actions.createTable.colLength') }}</span>
+            <span class="text-center col-span-1">NOT NULL</span>
+            <span class="text-center col-span-1">{{ t('sidebar.databases.actions.createTable.colAutoInc') }}</span>
+            <span class="text-center col-span-1">PK</span>
+            <span class="col-span-2">{{ t('sidebar.databases.actions.createTable.colDefault') }}</span>
+            <span class="col-span-1" />
+          </div>
+
+          <!-- Column rows -->
+          <div
+            v-for="(col, index) in columns"
+            :key="col.id"
+            class="px-1 py-0.5 rounded gap-1 grid grid-cols-12 items-center hover:bg-accent/20"
+          >
+            <!-- Move buttons -->
+            <div class="flex gap-0.5 col-span-1">
+              <button
+                class="text-muted-foreground flex h-4 w-4 cursor-pointer items-center justify-center hover:text-foreground disabled:opacity-20 disabled:cursor-not-allowed"
+                :disabled="index === 0"
+                @click="moveColumn(index, -1)"
+              >
+                <span class="i-lucide-chevron-up h-3 w-3" />
+              </button>
+              <button
+                class="text-muted-foreground flex h-4 w-4 cursor-pointer items-center justify-center hover:text-foreground disabled:opacity-20 disabled:cursor-not-allowed"
+                :disabled="index === columns.length - 1"
+                @click="moveColumn(index, 1)"
+              >
+                <span class="i-lucide-chevron-down h-3 w-3" />
+              </button>
+            </div>
+
+            <!-- Name -->
+            <Input
+              v-model="col.name"
+              :placeholder="`col_${index + 1}`"
+              class="text-xs col-span-2 h-7"
+            />
+
+            <!-- Type -->
+            <select
+              v-model="col.type"
+              class="text-xs px-2 border border-input rounded-md bg-background col-span-2 h-7"
+            >
+              <option v-for="colType in COMMON_TYPES" :key="colType" :value="colType">
+                {{ colType.toLowerCase() }}
+              </option>
+            </select>
+
+            <!-- Length -->
+            <Input
+              v-model="col.length"
+              :placeholder="t('sidebar.databases.actions.createTable.lengthPlaceholder')"
+              class="text-xs col-span-1 h-7"
+              :disabled="!['VARCHAR', 'CHAR', 'DECIMAL', 'NUMERIC'].includes(col.type)"
+            />
+
+            <!-- Not null -->
+            <div class="flex col-span-1 justify-center">
+              <input
+                :checked="!col.nullable"
+                type="checkbox"
+                class="accent-primary h-3.5 w-3.5"
+                @change="col.nullable = !($event.target as HTMLInputElement).checked"
+              >
+            </div>
+            <div class="flex col-span-1 justify-center">
+              <input
+                v-model="col.autoIncrement"
+                type="checkbox"
+                class="accent-primary h-3.5 w-3.5"
+              >
+            </div>
+            <div class="flex col-span-1 justify-center">
+              <input
+                v-model="col.primaryKey"
+                type="checkbox"
+                class="accent-primary h-3.5 w-3.5"
+              >
+            </div>
+
+            <!-- Default -->
+            <Input
+              v-model="col.defaultValue"
+              :placeholder="t('sidebar.databases.actions.createTable.defaultPlaceholder')"
+              class="text-xs col-span-2 h-7"
+            />
+
+            <!-- Remove -->
+            <div class="flex col-span-1 justify-center">
+              <button
+                class="text-muted-foreground flex h-5 w-5 cursor-pointer items-center justify-center hover:text-destructive disabled:opacity-20 disabled:cursor-not-allowed"
+                :disabled="columns.length <= 1"
+                @click="removeColumn(col.id)"
+              >
+                <span class="i-lucide-x h-3.5 w-3.5" />
+              </button>
+            </div>
+          </div>
+        </div>
+
+        <!-- SQL Preview -->
+        <div v-if="ddlPreview" class="space-y-1">
+          <Label class="text-xs font-medium">{{ t('sidebar.databases.actions.createTable.preview') }}</Label>
+          <pre class="text-xs font-mono p-2 border rounded-md bg-muted/50 whitespace-pre-wrap overflow-x-auto">{{ ddlPreview }}</pre>
+        </div>
+      </div>
+
+      <DialogFooter>
+        <Button variant="outline" size="sm" @click="emit('update:open', false)">
+          {{ t('sidebar.databases.actions.createTable.cancel') }}
+        </Button>
+        <Button
+          size="sm"
+          :disabled="!tableName.trim() || !columns.some(c => c.name.trim())"
+          @click="handleCreate"
+        >
+          {{ t('sidebar.databases.actions.createTable.create') }}
+        </Button>
+      </DialogFooter>
+    </DialogContent>
+  </Dialog>
+</template>
diff --git a/src/components/sidebar/DropDatabaseDialog.vue b/src/components/sidebar/DropDatabaseDialog.vue
new file mode 100644
index 0000000..eddc9f5
--- /dev/null
+++ b/src/components/sidebar/DropDatabaseDialog.vue
@@ -0,0 +1,74 @@
+<script setup lang="ts">
+import { ref, watch } from 'vue'
+import { useI18n } from 'vue-i18n'
+import { Button } from '@/components/ui/button'
+import {
+  Dialog,
+  DialogContent,
+  DialogDescription,
+  DialogFooter,
+  DialogHeader,
+  DialogTitle,
+} from '@/components/ui/dialog'
+import { Input } from '@/components/ui/input'
+
+type Props = {
+  open: boolean
+  databaseName: string | null
+}
+
+const props = defineProps<Props>()
+
+const emit = defineEmits<{
+  (e: 'update:open', value: boolean): void
+  (e: 'confirm'): void
+}>()
+
+const { t } = useI18n()
+const typedName = ref('')
+
+watch(() => props.open, (open) => {
+  if (open)
+    typedName.value = ''
+})
+
+const isMatch = () => typedName.value.trim() === (props.databaseName || '')
+</script>
+
+<template>
+  <Dialog :open="open" @update:open="(v: boolean) => emit('update:open', v)">
+    <DialogContent class="sm:max-w-[400px]">
+      <DialogHeader>
+        <DialogTitle>{{ t('sidebar.databases.actions.dropDatabase.title') }}</DialogTitle>
+        <DialogDescription>
+          {{ t('sidebar.databases.actions.dropDatabase.message', { name: databaseName }) }}
+        </DialogDescription>
+      </DialogHeader>
+
+      <div class="space-y-2">
+        <p class="text-xs text-destructive font-medium">
+          {{ t('sidebar.databases.actions.dropDatabase.typeToConfirm') }}
+        </p>
+        <Input
+          v-model="typedName"
+          :placeholder="databaseName || ''"
+          class="text-xs border-destructive/50"
+        />
+      </div>
+
+      <DialogFooter>
+        <Button variant="outline" size="sm" @click="emit('update:open', false)">
+          {{ t('sidebar.databases.actions.dropDatabase.cancel') }}
+        </Button>
+        <Button
+          variant="destructive"
+          size="sm"
+          :disabled="!isMatch()"
+          @click="emit('confirm')"
+        >
+          {{ t('sidebar.databases.actions.dropDatabase.confirm') }}
+        </Button>
+      </DialogFooter>
+    </DialogContent>
+  </Dialog>
+</template>
diff --git a/src/components/sidebar/index.ts b/src/components/sidebar/index.ts
index adde538..a49d890 100644
--- a/src/components/sidebar/index.ts
+++ b/src/components/sidebar/index.ts
@@ -1,9 +1,13 @@
 export { default as ChangeConnectionDialog } from './ChangeConnectionDialog.vue'
 export { default as ConnectionSelector } from './ConnectionSelector.vue'
+export { default as CreateDatabaseDialog } from './CreateDatabaseDialog.vue'
+export { default as CreateObjectDialog } from './CreateObjectDialog.vue'
+export { default as CreateTableDialog } from './CreateTableDialog.vue'
 export { default as DatabaseSelectorRow } from './DatabaseSelectorRow.vue'
 export { getDbCapabilities } from './dbCapabilities'
 export type { DbCapabilities } from './dbCapabilities'
 export { default as DeleteQueryDialog } from './DeleteQueryDialog.vue'
+export { default as DropDatabaseDialog } from './DropDatabaseDialog.vue'
 export { default as RenameQueryDialog } from './RenameQueryDialog.vue'
 export { default as SavedQueriesPanel } from './SavedQueriesPanel.vue'
 export { default as SavedQueryItem } from './SavedQueryItem.vue'
diff --git a/src/lang/enUS.ts b/src/lang/enUS.ts
index d21e2aa..f899301 100644
--- a/src/lang/enUS.ts
+++ b/src/lang/enUS.ts
@@ -1232,8 +1232,9 @@ export const enUS = {
         deleteFailed: 'Failed to delete row',
         rowUpdated: 'Row updated',
         updateFailed: 'Failed to update row',
-        noPrimaryKey: 'Cannot edit row',
-        noPrimaryKeyDesc: 'This table has no primary key column detected. Row editing requires a primary key.',
+        noPrimaryKey: 'No primary key detected',
+        noPrimaryKeyDesc: 'This table has no primary key. Row will be identified by all columns.',
+        fallbackAllColumns: 'No primary key — using all columns to identify the row. Edit with caution.',
       },
       deleteDialog: {
         title: 'Delete Row',
@@ -1485,6 +1486,65 @@ export const enUS = {
       refresh: 'Refresh',
       refreshTooltip: 'Reload database list',
     },
+    databases: {
+      actions: {
+        createObject: {
+          title: 'Create {type}',
+          placeholder: 'Enter {type} name',
+          cancel: 'Cancel',
+          confirm: 'Create',
+          created: '{type} "{name}" created successfully',
+          error: 'Failed to create: {error}',
+          types: {
+            database: 'Database',
+            schema: 'Schema',
+          },
+        },
+        createDatabase: {
+          title: 'Create Database',
+          name: 'Database Name',
+          namePlaceholder: 'Enter database name',
+          charset: 'Character Set',
+          collation: 'Collation',
+          collationPlaceholder: 'e.g. utf8mb4_unicode_ci',
+          encoding: 'Encoding',
+          locale: 'Locale / LC_COLLATE',
+          localePlaceholder: 'e.g. en_US.UTF-8',
+          optional: 'optional',
+          cancel: 'Cancel',
+          confirm: 'Create',
+        },
+        dropDatabase: {
+          title: 'Drop Database',
+          message: 'Are you sure you want to drop "{name}"? This action cannot be undone.',
+          typeToConfirm: 'Type the database name to confirm:',
+          cancel: 'Cancel',
+          confirm: 'Drop',
+          success: 'Database "{name}" dropped successfully',
+          error: 'Failed to drop database: {error}',
+        },
+        createTable: {
+          title: 'Create Table',
+          tableName: 'Table Name',
+          tableNamePlaceholder: 'Enter table name',
+          engine: 'Engine',
+          columns: 'Columns',
+          addColumn: 'Add Column',
+          colName: 'Name',
+          colType: 'Type',
+          colLength: 'Length',
+          colAutoInc: 'AI',
+          colDefault: 'Default',
+          lengthPlaceholder: '255',
+          defaultPlaceholder: 'NULL',
+          preview: 'SQL Preview',
+          cancel: 'Cancel',
+          create: 'Create',
+          opened: 'Table SQL opened in editor. Execute it to create the table.',
+        },
+        templateOpened: 'New {type} template opened in editor.',
+      },
+    },
     actionMenu: {
       label: 'Database actions',
       newDatabase: 'New Database',
diff --git a/src/lang/zhCN.ts b/src/lang/zhCN.ts
index a6d7217..b1a892a 100644
--- a/src/lang/zhCN.ts
+++ b/src/lang/zhCN.ts
@@ -1171,8 +1171,9 @@ export const zhCN = {
         deleteFailed: '删除行失败',
         rowUpdated: '行已更新',
         updateFailed: '更新行失败',
-        noPrimaryKey: '无法编辑行',
-        noPrimaryKeyDesc: '此表未检测到主键列。编辑行需要主键。',
+        noPrimaryKey: '未检测到主键',
+        noPrimaryKeyDesc: '此表无主键，将使用所有列来标识行。',
+        fallbackAllColumns: '未检测到主键，使用所有列标识行。编辑时请谨慎。',
       },
       deleteDialog: {
         title: '删除行',
@@ -1485,6 +1486,65 @@ export const zhCN = {
       refresh: '刷新',
       refreshTooltip: '重新加载数据库列表',
     },
+    databases: {
+      actions: {
+        createObject: {
+          title: '创建{type}',
+          placeholder: '输入{type}名称',
+          cancel: '取消',
+          confirm: '创建',
+          created: '{type} "{name}" 创建成功',
+          error: '创建失败: {error}',
+          types: {
+            database: '数据库',
+            schema: '模式',
+          },
+        },
+        createDatabase: {
+          title: '创建数据库',
+          name: '数据库名称',
+          namePlaceholder: '输入数据库名',
+          charset: '字符集',
+          collation: '排序规则',
+          collationPlaceholder: '例如 utf8mb4_unicode_ci',
+          encoding: '编码',
+          locale: '区域设置',
+          localePlaceholder: '例如 en_US.UTF-8',
+          optional: '可选',
+          cancel: '取消',
+          confirm: '创建',
+        },
+        dropDatabase: {
+          title: '删除数据库',
+          message: '确定要删除 "{name}" 吗？此操作无法撤销。',
+          typeToConfirm: '输入数据库名称以确认:',
+          cancel: '取消',
+          confirm: '删除',
+          success: '数据库 "{name}" 已删除',
+          error: '删除数据库失败: {error}',
+        },
+        createTable: {
+          title: '创建表',
+          tableName: '表名',
+          tableNamePlaceholder: '输入表名',
+          engine: '引擎',
+          columns: '列',
+          addColumn: '添加列',
+          colName: '名称',
+          colType: '类型',
+          colLength: '长度',
+          colAutoInc: '自增',
+          colDefault: '默认值',
+          lengthPlaceholder: '255',
+          defaultPlaceholder: 'NULL',
+          preview: 'SQL 预览',
+          cancel: '取消',
+          create: '创建',
+          opened: '表 SQL 已打开到编辑器中，执行它以创建表。',
+        },
+        templateOpened: '新的{type}模板已打开到编辑器中。',
+      },
+    },
     actionMenu: {
       label: '数据库操作',
       newDatabase: '新建数据库',
diff --git a/src/pages/QueriesPage.vue b/src/pages/QueriesPage.vue
index a7d5c9a..4d9581c 100644
--- a/src/pages/QueriesPage.vue
+++ b/src/pages/QueriesPage.vue
@@ -2,6 +2,7 @@
 import type { StatementToExecute } from '@/composables/useSqlStatements'
 import type { DatabaseType } from '@/store/connectionStore'
 import type { TableInfo } from '@/store/databaseStore'
+import type { ApiResponse } from '@/types/api'
 import { invoke } from '@tauri-apps/api/core'
 import { computed, onMounted, onUnmounted, ref, watch } from 'vue'
 import { useI18n } from 'vue-i18n'
@@ -10,7 +11,7 @@ import { DataTableView, DbTypeIcon, QueryResultPanel, QueryTabs } from '@/compon
 import ListingTab from '@/components/database-browser/ListingTab.vue'
 import ErDiagramView from '@/components/er-diagram/ErDiagramView.vue'
 import AppLayout from '@/components/layout/AppLayout.vue'
-import { ConnectionSelector, DatabaseSelectorRow, SavedQueriesPanel, SchemaTree, SidebarSplitView } from '@/components/sidebar'
+import { ConnectionSelector, CreateDatabaseDialog, CreateObjectDialog, CreateTableDialog, DatabaseSelectorRow, DropDatabaseDialog, SavedQueriesPanel, SchemaTree, SidebarSplitView } from '@/components/sidebar'
 import SQLEditor from '@/components/SQLEditor.vue'
 import { AlertDialog, AlertDialogAction, AlertDialogCancel, AlertDialogContent, AlertDialogDescription, AlertDialogFooter, AlertDialogHeader, AlertDialogTitle } from '@/components/ui/alert-dialog'
 import { Button } from '@/components/ui/button'
@@ -21,6 +22,7 @@ import { usePlatform } from '@/composables/usePlatform'
 import { useSqlFormatter } from '@/composables/useSqlFormatter'
 import { browseApi, loadQueryFile, saveQueryFile, saveQueryFileAs, saveQueryMetadata } from '@/datasources'
 import { ConnectionStatus, useAppStore, useConnectionStore, useDatabaseStore, useTabStore } from '@/store'
+import { isApiSuccess } from '@/types/api'
 
 const { t } = useI18n()
 const route = useRoute()
@@ -50,6 +52,13 @@ const isDestructiveActionExecuting = ref(false)
 const showOrphanTabDialog = ref(false)
 const orphanTabToHandle = ref<string | null>(null)
 
+// ── Database action dialog state ──
+const createDatabaseDialogOpen = ref(false)
+const createSchemaDialogOpen = ref(false)
+const dropDatabaseDialogOpen = ref(false)
+const createTableDialogOpen = ref(false)
+const isDatabaseActionExecuting = ref(false)
+
 // Get active connection ID (can be changed by user)
 const selectedConnectionId = ref<string>('')
 
@@ -657,8 +666,228 @@ function handleDatabaseRefresh() {
   schemaTreeRef.value?.refresh()
 }
 
-function handleDatabaseAction(_kind: string) {
-  toast.info(t('sidebar.notImplemented'))
+function handleDatabaseAction(kind: string) {
+  switch (kind) {
+    case 'newDatabase':
+      createDatabaseDialogOpen.value = true
+      break
+    case 'newSchema':
+      createSchemaDialogOpen.value = true
+      break
+    case 'dropDatabase':
+      dropDatabaseDialogOpen.value = true
+      break
+    case 'newTable':
+      createTableDialogOpen.value = true
+      break
+    case 'newView':
+    case 'newFunction':
+    case 'newProcedure':
+      openTemplateTab(kind)
+      break
+    case 'backupDatabase':
+    case 'exportDatabase':
+      router.push('/transfer')
+      break
+    default:
+      toast.info(t('sidebar.notImplemented'))
+  }
+}
+
+// ── Database CRUD handlers ──
+
+async function handleCreateDatabase(name: string, options: { charset?: string, collation?: string, encoding?: string, locale?: string }) {
+  const connId = getActiveConnectionId()
+  if (!connId)
+    return
+  isDatabaseActionExecuting.value = true
+  try {
+    const dbType = activeConnection.value?.type
+
+    // Build database-specific CREATE DATABASE SQL
+    const MYSQL_SET = new Set(['MYSQL', 'MARIADB', 'TIDB', 'OCEANBASE', 'TDSQL', 'POLARDB', 'DORIS', 'SELECTDB', 'STARROCKS', 'DATABEND', 'GOLDENDB', 'MANTICORESEARCH', 'SINGLESTOREMEMSQL', 'CLOUDSQLMYSQL'])
+    const PG_SET = new Set(['POSTGRESQL', 'COCKROACHDB', 'REDSHIFT', 'YUGABYTEDB', 'TIMESCALEDB', 'KINGBASEES', 'GAUSSDB', 'HIGHGO', 'UXDB', 'OPENGAUSS', 'GBASE8C', 'QUESTDB', 'VASTBASE', 'YASHANDB', 'GREENPLUM', 'ENTERPRISEDB', 'CRATEDB', 'MATERIALIZE', 'ALLOYDB', 'CLOUDSQLPG', 'FUJITSUPG'])
+    const MSSQL_SET = new Set(['SQLSERVER', 'HANA'])
+
+    let sql: string
+    if (dbType && MYSQL_SET.has(dbType)) {
+      sql = `CREATE DATABASE \`${name}\``
+      if (options.charset)
+        sql += ` CHARACTER SET ${options.charset}`
+      if (options.collation)
+        sql += ` COLLATE ${options.collation}`
+    }
+    else if (dbType && PG_SET.has(dbType)) {
+      sql = `CREATE DATABASE "${name}"`
+      if (options.encoding)
+        sql += ` ENCODING '${options.encoding}'`
+      if (options.locale)
+        sql += ` LC_COLLATE '${options.locale}'`
+    }
+    else if (dbType && MSSQL_SET.has(dbType)) {
+      sql = `CREATE DATABASE [${name}]`
+    }
+    else {
+      sql = `CREATE DATABASE ${name}`
+    }
+
+    const result: ApiResponse<unknown> = await invoke('execute_query', {
+      connectionId: connId,
+      sql,
+    })
+    if (!isApiSuccess(result))
+      throw new Error(result.error?.message || 'Unknown error')
+    toast.success(t('sidebar.databases.actions.createObject.created', { type: t('sidebar.databases.actions.createObject.types.database'), name }))
+    createDatabaseDialogOpen.value = false
+    // Refresh database list without switching to Mode A
+    await databaseStore.fetchDatabases(connId)
+  }
+  catch (err) {
+    toast.error(t('sidebar.databases.actions.createObject.error', { error: String(err) }))
+  }
+  finally {
+    isDatabaseActionExecuting.value = false
+  }
+}
+
+async function handleCreateSchema(name: string) {
+  const connId = getActiveConnectionId()
+  if (!connId)
+    return
+  isDatabaseActionExecuting.value = true
+  try {
+    const result: ApiResponse<unknown> = await invoke('execute_query', {
+      connectionId: connId,
+      sql: `CREATE SCHEMA ${name}`,
+    })
+    if (!isApiSuccess(result))
+      throw new Error(result.error?.message || 'Unknown error')
+    toast.success(t('sidebar.databases.actions.createObject.created', { type: t('sidebar.databases.actions.createObject.types.schema'), name }))
+    createSchemaDialogOpen.value = false
+    schemaTreeRef.value?.refresh()
+  }
+  catch (err) {
+    toast.error(t('sidebar.databases.actions.createObject.error', { error: String(err) }))
+  }
+  finally {
+    isDatabaseActionExecuting.value = false
+  }
+}
+
+async function handleDropDatabase() {
+  const connId = getActiveConnectionId()
+  const dbName = selectedDatabase.value
+  if (!connId || !dbName)
+    return
+  isDatabaseActionExecuting.value = true
+  try {
+    const dbType = activeConnection.value?.type
+    const MYSQL_SET = new Set(['MYSQL', 'MARIADB', 'TIDB', 'OCEANBASE', 'TDSQL', 'POLARDB', 'DORIS', 'SELECTDB', 'STARROCKS', 'DATABEND', 'GOLDENDB', 'MANTICORESEARCH', 'SINGLESTOREMEMSQL', 'CLOUDSQLMYSQL'])
+    const PG_SET = new Set(['POSTGRESQL', 'COCKROACHDB', 'REDSHIFT', 'YUGABYTEDB', 'TIMESCALEDB', 'KINGBASEES', 'GAUSSDB', 'HIGHGO', 'UXDB', 'OPENGAUSS', 'GBASE8C', 'QUESTDB', 'VASTBASE', 'YASHANDB', 'GREENPLUM', 'ENTERPRISEDB', 'CRATEDB', 'MATERIALIZE', 'ALLOYDB', 'CLOUDSQLPG', 'FUJITSUPG'])
+    const MSSQL_SET = new Set(['SQLSERVER', 'HANA'])
+
+    let sql: string
+    if (dbType && MYSQL_SET.has(dbType))
+      sql = `DROP DATABASE \`${dbName}\``
+    else if (dbType && PG_SET.has(dbType))
+      sql = `DROP DATABASE "${dbName}"`
+    else if (dbType && MSSQL_SET.has(dbType))
+      sql = `DROP DATABASE [${dbName}]`
+    else
+      sql = `DROP DATABASE ${dbName}`
+
+    const result: ApiResponse<unknown> = await invoke('execute_query', {
+      connectionId: connId,
+      sql,
+    })
+    if (!isApiSuccess(result))
+      throw new Error(result.error?.message || 'Unknown error')
+    toast.success(t('sidebar.databases.actions.dropDatabase.success', { name: dbName }))
+    dropDatabaseDialogOpen.value = false
+    selectedDatabase.value = ''
+    // Refresh database list after dropping
+    await databaseStore.fetchDatabases(connId)
+  }
+  catch (err) {
+    toast.error(t('sidebar.databases.actions.dropDatabase.error', { error: String(err) }))
+  }
+  finally {
+    isDatabaseActionExecuting.value = false
+  }
+}
+
+function handleCreateTable(tableName: string, sql: string) {
+  const connId = getActiveConnectionId()
+  if (!connId)
+    return
+
+  const tab = tabStore.createTab(connId, selectedDatabase.value, selectedSchema.value)
+  tabStore.updateTabName(tab.id, `${tableName}.sql`)
+  tabStore.updateTabContent(tab.id, sql)
+  createTableDialogOpen.value = false
+  toast.success(t('sidebar.databases.actions.createTable.opened'))
+}
+
+function openTemplateTab(kind: string) {
+  const connId = getActiveConnectionId()
+  if (!connId)
+    return
+
+  const typeLabel = kind.replace('new', '').toUpperCase()
+  const tab = tabStore.createTab(connId, selectedDatabase.value, selectedSchema.value)
+  tabStore.updateTabName(tab.id, `new_${kind.replace('new', '').toLowerCase()}.sql`)
+  tabStore.updateTabContent(tab.id, getTemplateSQL(kind))
+  toast.info(t('sidebar.databases.actions.templateOpened', { type: typeLabel }))
+}
+
+function getTemplateSQL(kind: string): string {
+  const qualified = selectedSchema.value ? `${selectedSchema.value}.` : ''
+
+  switch (kind) {
+    case 'newView':
+      return [
+        `CREATE VIEW ${qualified}your_view_name AS`,
+        'SELECT',
+        '  *',
+        `FROM ${qualified}your_table`,
+        'WHERE',
+        '  your_condition;',
+        '',
+        `-- Note: Replace placeholders above before executing.`,
+      ].join('\n')
+
+    case 'newFunction':
+      return [
+        `CREATE OR REPLACE FUNCTION ${qualified}your_function_name()`,
+        'RETURNS void',
+        'LANGUAGE plpgsql',
+        'AS $$',
+        'BEGIN',
+        '  -- TODO: Implement function body',
+        '  -- E.g.: INSERT INTO audit_log (action) VALUES (\'your_action\');',
+        'END;',
+        '$$;',
+        '',
+        `-- Note: Replace placeholders above before executing.`,
+      ].join('\n')
+
+    case 'newProcedure':
+      return [
+        `CREATE OR REPLACE PROCEDURE ${qualified}your_procedure_name()`,
+        'LANGUAGE plpgsql',
+        'AS $$',
+        'BEGIN',
+        '  -- TODO: Implement procedure body',
+        '  -- E.g.: UPDATE your_table SET updated_at = NOW() WHERE id = 1;',
+        'END;',
+        '$$;',
+        '',
+        `-- Note: Replace placeholders above before executing.`,
+      ].join('\n')
+
+    default:
+      return '-- Select SQL to execute'
+  }
 }
 
 function startSidebarResize(_e: MouseEvent) {
@@ -822,7 +1051,7 @@ function closeResultPanel() {
                     <Button
                       variant="ghost"
                       size="sm"
-                      class="text-foreground p-0 h-9 w-9 hover:bg-muted"
+                      class="text-green-600 p-0 h-9 w-9 dark:text-green-400 hover:bg-accent disabled:opacity-40"
                       :disabled="!activeTab || activeTab.orphanFromConnectionId"
                       @click="executeQuery"
                     >
@@ -841,12 +1070,12 @@ function closeResultPanel() {
                     <Button
                       variant="ghost"
                       size="sm"
-                      class="text-foreground p-0 h-9 w-9 hover:bg-muted"
-                      :class="{ '!text-violet-600': !explainAnalyzeMode, '!text-green-600': explainAnalyzeMode }"
+                      class="p-0 h-9 w-9 hover:bg-accent"
+                      :class="{ '!text-amber-500': !explainAnalyzeMode, '!text-emerald-500': explainAnalyzeMode }"
                       :disabled="!activeTab || activeTab.orphanFromConnectionId || activeTab.isExplaining"
                       @click="handleExplainQuery(explainAnalyzeMode)"
                     >
-                      <span class="i-carbon-wand h-5 w-5" />
+                      <span class="i-carbon-diagram h-5 w-5" />
                     </Button>
                   </TooltipTrigger>
                   <TooltipContent>
@@ -860,8 +1089,8 @@ function closeResultPanel() {
                     <Button
                       variant="ghost"
                       size="sm"
-                      class="text-foreground p-0 h-9 w-9 hover:bg-muted"
-                      :class="explainAnalyzeMode ? '!text-green-600 bg-green-100 dark:text-green-300 dark:bg-green-900/30' : ''"
+                      class="p-0 h-9 w-9 hover:bg-accent"
+                      :class="explainAnalyzeMode ? '!text-violet-600 bg-violet-100 dark:text-violet-300 dark:bg-violet-900/30' : ''"
                       :disabled="!activeTab || activeTab.orphanFromConnectionId || activeTab.isExplaining"
                       @click="toggleExplainMode"
                     >
@@ -880,7 +1109,7 @@ function closeResultPanel() {
                     <Button
                       variant="ghost"
                       size="sm"
-                      class="text-foreground p-0 h-9 w-9 hover:bg-muted"
+                      class="text-blue-600 p-0 h-9 w-9 dark:text-blue-400 hover:bg-accent disabled:opacity-40"
                       :disabled="!activeTab || activeTab.orphanFromConnectionId"
                       @click="handleToolbarFormat"
                     >
@@ -902,11 +1131,11 @@ function closeResultPanel() {
                     <Button
                       variant="ghost"
                       size="sm"
-                      class="p-0 h-7 w-7"
+                      class="p-0 h-9 w-9 hover:bg-accent"
                       :disabled="!activeTab || !activeTab.content.trim()"
                       @click="handleDownloadQuery"
                     >
-                      <span class="i-carbon-download h-3.5 w-3.5" />
+                      <span class="i-carbon-download text-muted-foreground h-5 w-5" />
                     </Button>
                   </TooltipTrigger>
                   <TooltipContent>
@@ -1068,5 +1297,39 @@ function closeResultPanel() {
         </AlertDialogFooter>
       </AlertDialogContent>
     </AlertDialog>
+
+    <!-- Create Database dialog -->
+    <CreateDatabaseDialog
+      :open="createDatabaseDialogOpen"
+      :database-type="activeConnection?.type"
+      @update:open="(v: boolean) => createDatabaseDialogOpen = v"
+      @confirm="handleCreateDatabase"
+    />
+
+    <!-- Create Schema dialog -->
+    <CreateObjectDialog
+      :open="createSchemaDialogOpen"
+      object-type="schema"
+      @update:open="(v: boolean) => createSchemaDialogOpen = v"
+      @confirm="handleCreateSchema"
+    />
+
+    <!-- Drop Database dialog -->
+    <DropDatabaseDialog
+      :open="dropDatabaseDialogOpen"
+      :database-name="selectedDatabase"
+      @update:open="(v: boolean) => dropDatabaseDialogOpen = v"
+      @confirm="handleDropDatabase"
+    />
+
+    <!-- Create Table dialog -->
+    <CreateTableDialog
+      :open="createTableDialogOpen"
+      :database="selectedDatabase"
+      :schema="selectedSchema || null"
+      :database-type="activeConnection?.type"
+      @update:open="(v: boolean) => createTableDialogOpen = v"
+      @create="handleCreateTable"
+    />
   </AppLayout>
 </template>