python-dbhelper

sql = 'DELETE TABLE user where id=1'
users = helper.execute(sql=sql)

# 1、MySQL
from dbhelper.mysql.mysqlhelper import MySQLHelper
dbconfg = {
    'host':'127.0.0.1',
    'port':3306,
    'username':'root',
    'password':'****',
    'db':'test',
    'charset':'utf8'
}
helper = MySQLHelper(dbconfg)

# 判断表是否存在
print(helper.table_is_exist('tablename'))

# 不带参数查询
sql = "select * from user"
users = helper.select(sql=sql)
print(users)

# 不带参数查询前10条
sql = "select * from user"
users = helper.select(sql=sql,size=10)
print(users)

# 带参数查询
sql = "select * from user where id=%s"
users = helper.select(sql=sql,param=(1,))
print(users)

# DML语句：INSERT UPDATE DELETE
sql = "delete from user where id=10"
# sql = "INSERT INTO user (username , password , email , sal) VALUES ('test','分钟都干啥的','test@163.com',5000);"
users = helper.execute(sql=sql)
print(users)



# 2、Hive
from dbhelper.hive.hivehelper import HiveHelper
dbconfg = {
    'host': '127.0.0.1',
    'port': 10000,
    'db':'test',
    'username': 'test'
}
helper = HiveHelper(dbconfg)
sql = "select * from user" # Hive sql结尾不能有;分号
users = helper.select(sql=sql)
print(users)


# 3、SqlServer
from dbhelper.sqlserver.sqlserverhelper import SqlServerHelper
dbconfg = {
    'host': '127.0.0.1',
    'port': 2121,
    'db':'test',
    'username': 'test',
    'password': 'test'
}
helper = SqlServerHelper(dbconfg)
sql = "select * from user"
users = helper.select(sql=sql)
print(users)


# 4、Oracle
from dbhelper.oracle.oraclehelper import OracleHelper
dbconfg = {
    'host': '127.0.0.1',
    'port': 1521,
    'db':'orcl',
    'username': 'test',
    'password': 'test'
}
helper = OracleHelper(dbconfg)
sql = "select * from user"
users = helper.select(sql=sql)
print(users)