您的位置：首页 > 数据库 > SQL

scala 执行 hive,hadoop,mysql等命令

2016-07-04 15:49 881 查看 
import java.sql.{DriverManager, Connection, ResultSet}
import scala.sys.process.Processobject Test2 {def main(args: Array[String]) {print(execute())}
def execute(): Int = {
var seq=Seq("mysql",
"-h"+"192.168.199.36",
"-u"+ "root",
"-p"+ "****" + "",
"-D" + "dbname",
"-e",
"SELECT id, name FROM city")
print(seq)
val processBuilder = Process(seq)
val exitCode = processBuilder.!
//    if(exitCode!=0) {
//      case _ : Exception => println("===>")
//    }
exitCode
}
}
执行hive命令
 def execute(query: String) = {val seq =  Seq("hive","-e",query)val processBuilder =Process(seq)val exitCode = processBuilder.!if(exitCode!=0) {throw new HiveExecException("Error occured while executing hive -e command:" + query)}}

                                            

                                        

                        
                        内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息 
                    

                    

                    

                        

                         标签： 
                                                

                        

                    


                

            


            

                
相关文章推荐

                

                
            

        

        

            

            
            

                

                    
新的分享

                    

                        
                    

                

            


            

                

                    
章节导航