[修复]doris

pydbapi/api/mysql.py

@@ -1,7 +1,7 @@
 # @Author: chunyang.xu
 # @Email:  [email protected]
 # @Date:   2020-06-10 14:40:50
-# @Last Modified time: 2021-11-22 14:31:01
+# @Last Modified time: 2021-11-22 16:19:04
 # @github: https://github.com/longfengpili
 
 # !/usr/bin/env python3
@@ -138,12 +138,13 @@ def get_conn(self):
             self.get_conn()
         return conn
 
-    def create(self, tablename, columns, indexes=None, index_part=128, ismultiple_index=True, partition=None, verbose=0):
+    def create(self, tablename, columns, indexes=None, index_part=128, ismultiple_index=True,
+               partition=None, distribution=None, verbose=0):
         # tablename = f"{self.database}.{tablename}"
         sqlcompile = SqlMysqlCompile(tablename)
         sql_for_create = sqlcompile.create(columns, indexes, index_part=index_part,
                                            ismultiple_index=ismultiple_index, partition=partition,
-                                           isdoris=self.isdoris)
+                                           distribution=distribution, isdoris=self.isdoris)
         rows, action, result = self.execute(sql_for_create, verbose=verbose)
         return rows, action, result
 

setup.py

@@ -1,7 +1,7 @@
 # @Author: chunyang.xu
 # @Email:  [email protected]
 # @Date:   2020-06-09 16:46:54
-# @Last Modified time: 2021-11-20 14:58:40
+# @Last Modified time: 2021-11-22 16:19:23
 # @github: https://github.com/longfengpili
 
 # !/usr/bin/env python3
@@ -12,7 +12,7 @@
 import shutil
 import setuptools
 
-VERSION = '0.0.80'
+VERSION = '0.0.81'
 PROJECT_NAME = 'pydbapi'
 
 with open('README.md', 'r', encoding='utf-8') as f: