diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/config/jpa/type/JsonType.java b/server/odc-service/src/main/java/com/oceanbase/odc/config/jpa/type/JsonType.java
new file mode 100644
index 0000000000..ff26e9a1c2
--- /dev/null
+++ b/server/odc-service/src/main/java/com/oceanbase/odc/config/jpa/type/JsonType.java
@@ -0,0 +1,140 @@
+/*
+ * Copyright (c) 2023 OceanBase.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.oceanbase.odc.config.jpa.type;
+
+import java.io.Serializable;
+import java.lang.reflect.Field;
+import java.lang.reflect.Type;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Types;
+import java.util.Objects;
+import java.util.Properties;
+
+import org.hibernate.HibernateException;
+import org.hibernate.annotations.common.reflection.java.JavaXMember;
+import org.hibernate.engine.spi.SharedSessionContractImplementor;
+import org.hibernate.usertype.DynamicParameterizedType;
+import org.hibernate.usertype.UserType;
+
+import com.fasterxml.jackson.databind.JavaType;
+import com.oceanbase.odc.common.json.JsonUtils;
+
+public class JsonType implements UserType, DynamicParameterizedType {
+
+    private Class<?> returnedClass;
+
+    private JavaType targetJavaType;
+
+    @Override
+    public int[] sqlTypes() {
+        return new int[] {Types.CLOB};
+    }
+
+    @Override
+    public Class<?> returnedClass() {
+        return returnedClass;
+    }
+
+    @Override
+    public boolean equals(Object x, Object y) throws HibernateException {
+        return Objects.equals(x, y);
+    }
+
+    @Override
+    public int hashCode(Object x) throws HibernateException {
+        return x.hashCode();
+    }
+
+    @Override
+    public Object nullSafeGet(ResultSet rs, String[] names, SharedSessionContractImplementor session, Object owner)
+            throws HibernateException,
+            SQLException {
+        String value = rs.getString(names[0]);
+        return fromJson(value);
+    }
+
+    @Override
+    public void nullSafeSet(PreparedStatement st, Object value, int index, SharedSessionContractImplementor session)
+            throws HibernateException, SQLException {
+        if (value == null) {
+            st.setNull(index, Types.CLOB);
+            return;
+        }
+        st.setString(index, toJson(value));
+    }
+
+    private Object fromJson(String value) {
+        if (value == null) {
+            return null;
+        }
+        return JsonUtils.fromJson(value, targetJavaType);
+    }
+
+    private String toJson(Object value) {
+        if (value == null) {
+            return null;
+        }
+        return JsonUtils.toJson(value);
+    }
+
+    @Override
+    public Object deepCopy(Object value) throws HibernateException {
+        return fromJson(toJson(value));
+    }
+
+    @Override
+    public boolean isMutable() {
+        return true;
+    }
+
+    @Override
+    public Serializable disassemble(Object value) throws HibernateException {
+        throw new UnsupportedOperationException("disassemble is not supported");
+    }
+
+    @Override
+    public Object assemble(Serializable cached, Object owner) throws HibernateException {
+        throw new UnsupportedOperationException("assemble is not supported");
+    }
+
+    @Override
+    public Object replace(Object original, Object target, Object owner) throws HibernateException {
+        return original;
+    }
+
+    @Override
+    public void setParameterValues(Properties parameters) {
+        Object xProperty = parameters.get(DynamicParameterizedType.XPROPERTY);
+        Field annotatedField = (Field) getAnnotatedElement(xProperty);
+
+        returnedClass = annotatedField.getType();
+        Type type = annotatedField.getGenericType();
+        targetJavaType = JsonUtils.constructType(type);
+    }
+
+    private Object getAnnotatedElement(Object target) {
+        try {
+            Field field = JavaXMember.class.getSuperclass().getDeclaredField("annotatedElement");
+            field.setAccessible(true);
+            return field.get(target);
+        } catch (NoSuchFieldException | IllegalAccessException e) {
+            throw new AssertionError(e);
+        }
+    }
+
+}
diff --git a/server/odc-service/src/main/java/com/oceanbase/odc/metadb/package-info.java b/server/odc-service/src/main/java/com/oceanbase/odc/metadb/package-info.java
new file mode 100644
index 0000000000..be5f9b3af2
--- /dev/null
+++ b/server/odc-service/src/main/java/com/oceanbase/odc/metadb/package-info.java
@@ -0,0 +1,22 @@
+/*
+ * Copyright (c) 2024 OceanBase.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+@TypeDefs({@TypeDef(name = "Json", typeClass = JsonType.class)})
+package com.oceanbase.odc.metadb;
+
+import org.hibernate.annotations.TypeDef;
+import org.hibernate.annotations.TypeDefs;
+
+import com.oceanbase.odc.config.jpa.type.JsonType;
\ No newline at end of file