val driver = 「com.cloudera.impala.jdbc41.driver」
val url = 「jdbc:impala:
class.forname(driver)
val client = drivermanager.getconnection(url)
//注意:sql語句後面新增分號,估計是impala的乙個bug,不加分號會報錯
//報錯資訊:caused by: com.cloudera.support.exceptions.generalexception: [simba]impalajdbcdriver error during translation: code translation error, type , message
val sql = 「delete from table where date <= '」 + date + 「』;」
println(sql)
val ret = client.createstatement().execute(sql)
println("ret = " + ret)
//execute返回乙個boolean值,有結果為true,無結果為false,所以刪除和更新操作均返回false
if(!ret)
通過反射封裝JDBC
具體上 我的basedao 每個實體類都配置了個properties 用來存放每個實體類的類名 相當於資料庫裡的表明 和資料庫裡的主鍵自動增長列 tablename user mainkeytype identity idname id 我的userdao只要繼承basedao就行 public c...
JDBC操作技巧
對於純jdbc連線資料庫連線工具如下 public static final string dbdriver com.microsoft.sqlserver.jdbc.sqlserverdriver public static final string dburl jdbc sqlserver pu...
JDBC基本操作
jdbc基本操作 載入驅動 class.forname com.mysql.jdbc.driver newinstance 建立連線 string url jdbc mysql localhost 3306 testdb?user root password root useunicode true...