|
@@ -1,6 +1,7 @@
|
|
|
import time
|
|
|
from typing import List
|
|
|
from sqlalchemy.orm import Session
|
|
|
+from sqlalchemy import func
|
|
|
from app.core.datasource.datasource import DataSrouceFactory
|
|
|
import app.schemas as schemas
|
|
|
import app.models as models
|
|
@@ -80,7 +81,7 @@ def create_job_jdbc_datasource(db: Session, item: schemas.JobJdbcDatasourceCreat
|
|
|
raise Exception('连接失败,不允许添加')
|
|
|
create_time: int = int(time.time())
|
|
|
name_item = db.query(models.JobJdbcDatasource)\
|
|
|
- .filter(models.JobJdbcDatasource.datasource_name == item.datasource_name)\
|
|
|
+ .filter(models.JobJdbcDatasource.datasource_name == func.binary(item.datasource_name))\
|
|
|
.filter(models.JobJdbcDatasource.status == 1).first()
|
|
|
if name_item:
|
|
|
raise Exception('数据源名称重复')
|