Ehs8 with database | Thales IoT Developer Community

May 6, 2017 - 1:53am, 3672 views

Java

Good night.

I have a "DSB-mini" with a "DSB multi adapter a4" and "EHS 8" with a sim that take gps position, by other hand, I have installed on my desktop apache server with mysql.

How could I send the gps position from "EHS8" to my database? I have seen the netdemo example but I still don´t know how to do it.

Thanks for help.

Comment

Bartłomiej Gema...

May 8 2017 - 1:16pm

Hello,

The general solution is up to you. The Java API for the module provides the socket and http[s] connections.

Probably the easiest way would be to use HTTP POST to send the GPS data to the server. You can find the POST example in the API.

You would need some PHP script for example on the server to store the data to the database.

There's also XML API available so you could use it to format the data. To use JSON for example you'd need to find some library in the network and adopt it.

Regards,

Bartłomiej

Like
0
Log in or register to post comments

pitu

May 10 2017 - 10:19am

Good morning Bartlomiej, thank for answer.

Then I can´t do querys directly from ehs8 module as I have seen because module use Micro Edition (ME) :S.

I have seen api and looking for some example. Code will be similar this, no?

String url = "https://ip.folder.script";

HttpClient client = HttpClientBuilder.create().build();
HttpPost post = new HttpPost(url);

// add header
post.setHeader("User-Agent", USER_AGENT);

List<NameValuePair> urlParameters = new ArrayList<NameValuePair>();
urlParameters.add(new BasicNameValuePair("query", "blablablabla"));

post.setEntity(new UrlEncodedFormEntity(urlParameters));

HttpResponse response = client.execute(post);
System.out.println("Response Code : " + response.getStatusLine().getStatusCode());

BufferedReader rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

About script, if two ehs8 modules try to use php script at the same time, what would happened?

Thanks for help.

Like
0
Log in or register to post comments

Bartłomiej Gema...

May 10 2017 - 1:58pm

Hello,

To directly access the database you'd need some driver which is not provided by the standard API for the module.

Your example is for Java SE. Here we don't have HttpPost and generics but we do have HttpConnection interface. Let me paste the POST example with HttpConnection interface taken form our API for comparison:

void postViaHttpConnection(String url) throws IOException {

HttpConnection c = null;

InputStream is = null;

OutputStream os = null;

int rc;

try {

c = (HttpConnection)Connector.open(url);

// Set the request method and headers

c.setRequestMethod(HttpConnection.POST);

c.setRequestProperty("If-Modified-Since",

"29 Oct 1999 19:43:31 GMT");

c.setRequestProperty("User-Agent",

"Profile/MIDP-2.0 Configuration/CLDC-1.0");

c.setRequestProperty("Content-Language", "en-US");

// Getting the output stream may flush the headers

os = c.openOutputStream();

os.write("LIST games\n".getBytes());

os.flush(); // Optional, getResponseCode will flush

// Getting the response code will open the connection,

// send the request, and read the HTTP response headers.

// The headers are stored until requested.

rc = c.getResponseCode();

if (rc != HttpConnection.HTTP_OK) {

throw new IOException("HTTP response code: " + rc);

}

is = c.openInputStream();

// Get the ContentType

String type = c.getType();

processType(type);

// Get the length and process the data

int len = (int)c.getLength();

if (len > 0) {

int actual = 0;

int bytesread = 0 ;

byte[] data = new byte[len];

while ((bytesread != len) && (actual != -1)) {

actual = is.read(data, bytesread, len - bytesread);

bytesread += actual;

}

process(data);

} else {

int ch;

while ((ch = is.read()) != -1) {

process((byte)ch);

}

}

} catch (ClassCastException e) {

throw new IllegalArgumentException("Not an HTTP URL");

} finally {

if (is != null)

is.close();

if (os != null)

os.close();

if (c != null)

c.close();

}

}

As for the PHP script on the server side I think that this question is more accurate for Apache/PHP/MySQL forum. The database is transactional, Apache server must be prepared for multiple access and there are probably additional techniques to ensure concurrency without data loss or other errors. But I'm not the expert here.

Regards,

Bartłomiej

Like
0
Log in or register to post comments

pitu

May 14 2017 - 11:58am

Good morning Bartlomiej.

I`m doing something wrong maybe when I add post params because php script says me that no exits post params.

void postViaHttpConnection(){

String url = "http://external ip server/script name.php";

String connProfile = "bearer_type=gprs;access_point=****.es;username=****;password=****";

HttpConnection c = null;

InputStream is = null;

OutputStream os = null;

int rc;

try {

System.out.println("1");

c = (HttpConnection)Connector.open(url + ";" + connProfile);

// Set the request method and headers

c.setRequestMethod(HttpConnection.POST);

c.setRequestProperty("If-Modified-Since", "29 Oct 1999 19:43:31 GMT");

c.setRequestProperty("User-Agent", "IMEI");

c.setRequestProperty("Content-Language", "en-EN");

String urlParameters = "param1=2&param2=INSERT INTO **** (yyyy, zzzz) VALUES (y, z)";

// Getting the output stream may flush the headers

System.out.println("2");

os = c.openOutputStream();

os.write(urlParameters.getBytes());

os.flush(); // Optional, getResponseCode will flush

// Getting the response code will open the connection,

// send the request, and read the HTTP response headers.

// The headers are stored until requested.

System.out.println(3);

rc = c.getResponseCode();

if (rc != HttpConnection.HTTP_OK) {

throw new IOException("HTTP response code: " + rc);

}

is = c.openInputStream();

int data = is.read();

while(data != -1){

System.out.print((char) data);

}

The code run ok, without warnings, exceptions. But script says that params are undefined.

1

2

3

 

Notice: Undefined index: param1 in C:\.....\phpscript.php on line 5 

 

Notice: Undefined index: param2 in C:\.....\phpscript.php on line 6 

destroyApp(true)

End of debug session. Emulator is closed!

This is part of my script:

<?php

$var1 = $_POST['param1']; <----- line 5

$var2 = $_POST['param2']; <----- line 6

.....

?>

I have tried with eclipse in localhost and Java SE code without modifying php script and run perfect doing insert.

What i´m doing wrong?

Thanks for help.

Like
0
Log in or register to post comments

pitu

May 14 2017 - 10:40pm

I found the problem. I had to add:

c.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");

I have seen that only with this property all works, and when I open conector, connProfile is not neccesary:

String url = "http://external ip server/script name.php";

HttpConnection http = (HttpConnection) Connector.open(url);

Thank for all Bartlomiej.

Like
0
Log in or register to post comments

Bartłomiej Gema...

May 15 2017 - 11:56am

Hello,

Great! Thanks for the update.

Regards,

Bartłomiej

Like
0
Log in or register to post comments

You are here

Ehs8 with database | Thales IoT Developer Community