CodeProject

（ご案内）
CodeProject は、CodeProject が有用で、開発者にとって価値があると考えられた製品およびサービスに関する情報を提供することを目的に公開されているサイトです。

ここでは、Actian 製品に関連した公開情報の一部をお知らせしております。
なお、お知らせしている情報は、すべて CodeProject に著作権等、帰属しています。本サイトは、提供元より了承を得て、エージーテックが翻訳してご紹介しております。記載情報のご利用の際は、オリジナルサイトとあわせご確認ください。

  \\<ipv4_address>\c$

cd\

Expand-Archive -Path "C:\temp\install-zen.zip" -DestinationPath "C:\temp"

C:\temp\PSQL\Install-PSQL.ps1 server

using System;

namespace TempPressure
{
    public class Reading
    {
        public string DeviceName { get; set; }
        public double Temperature { get; set; }
        public double Pressure { get; set; }
        public double Altitude { get; set; }
        public DateTime ReadingTs { get; set; }
    }
}

using Pervasive.Data.SqlClient;
using System;
using System.Collections.Generic;
using System.Diagnostics;

namespace TempPressure
{
    public class ActianZenDataSource
    {

        private string _tableName = "UWP_SensorReadings";
        private PsqlConnection _conn = new 
PsqlConnection("Host=localhost;Port=1583;ServerDSN=DEMODATA;");
        private PsqlCommand _cmd = new PsqlCommand();

        private void _createTable()
        {
            if (!_tableExists())
            {
                var query = $@"CREATE TABLE {_tableName}(DeviceName varchar(50), Temperature 
double, Pressure double, Altitude double, ReadingTs datetime)";

                int recordsAffected = _executeNonQuery(query);
                Debug.WriteLine((recordsAffected == -1) ? "Table: '" + _tableName + "' 
Successfully Created !!\n" : string.Empty);

            }

        }

        public void DropTable()
        {
            if (_tableExists())
            {
                var query = $@"DROP TABLE {_tableName}";
                _executeNonQuery(query);
                if (_tableExists())
                {
                    Debug.WriteLine("Table not dropped\n");
                }
                else
                {
                    Debug.WriteLine("Table " + _tableName + " Successfully Dropped !!\n");
                }
            }
        }

        public void AddReading(Reading reading)
        {
            //Create Reading Record in database
            // **NOTE: SQL String is being generated for debug output reasons only, 
            //          IN PRODUCTION UTILIZE named parameters using the PsqlParameter object
            int recordsAffected = 0;
            var query = $@"INSERT INTO {_tableName} VALUES ( '{ reading.DeviceName }',{ 
reading.Temperature }, { reading.Pressure }, {reading.Altitude}, '{ 
reading.ReadingTs.ToString("yyyy-MM-dd HH:mm:ss") }'  )";
            if (!_tableExists())
            {
                this._createTable();
            }
            
            recordsAffected = _executeNonQuery(query);
            Debug.WriteLine("\nRecords Affected: " + recordsAffected + "\n\n");
        }

        public List<Reading> GetReadings()
        {
            var query = $"SELECT * FROM {_tableName}";
            PsqlDataReader rdr = null;
            string logText = string.Empty;
            List<Reading> retValue = new List<Reading>();

            if (_tableExists())
            {
                try
                {
                    if ((_conn.State != System.Data.ConnectionState.Open))
                    {
                        _conn.Open();
                    }
                    _cmd.Connection = _conn;
                    _cmd.CommandText = query;

                    logText = "Query Executed : " + query + "\n\n";
                    rdr = _cmd.ExecuteReader();
                    int rowCount = 0;

                    while (rdr.Read())
                    {
                        Reading rdg = new Reading();

                        rdg.DeviceName = rdr.GetString(0);
                        rdg.Temperature = rdr.GetDouble(1);
                        rdg.Pressure = rdr.GetDouble(2);
                        rdg.Altitude = rdr.GetDouble(3);
                        rdg.ReadingTs = rdr.GetDateTime(4);

                        retValue.Add(rdg);
                        rowCount++;
                    }
                    logText += "Total Rows :" + rowCount;
                }
                catch (Exception ex)
                {
                    logText = logText + "\nQuery execution failed with exception: " + 
ex.Message;
                }
                finally
                {
                    _conn.Close();
                }
                Debug.WriteLine(logText);
            }
            else
            {
                Debug.WriteLine("Table does not exist.");
            }
          
            return retValue;
        }


        private int _executeNonQuery(string query)
        {
            int rowsAffected = 0;
            var logText = string.Empty;
            try
            {
                if ((_conn.State != System.Data.ConnectionState.Open))
                {
                    _conn.Open();
                    Debug.WriteLine("Connection Opened: ");
                }
                _cmd.Connection = _conn;
                _cmd.CommandText = query;

                logText = "Query Executed : " + query + "\n\n";
                rowsAffected = _cmd.ExecuteNonQuery();

            }
            catch (Exception ex)
            {
                logText = logText + "Query execution failed with exception: " + ex.Message;
            }
            finally
            {
                _conn.Close();
            }
            Debug.WriteLine(logText);
            return rowsAffected;
        }

        private bool _tableExists()
        {
            bool result = false;
            int count = 0;
            try
            {
                if ((_conn.State != System.Data.ConnectionState.Open))
                {
                    _conn.Open();
                    Debug.WriteLine("Connection Opened: ");
                }
                _cmd.Connection = _conn;
                _cmd.CommandText = $"select count(*) from X$File where Xf$Name = 
'{_tableName}'";

                count = (int)_cmd.ExecuteScalar();
                result = (count >= 1);

            }
            catch (Exception ex)
            {
                Debug.WriteLine("**** Exception : " + ex.Message + " ****");
            }
            finally
            {
                _conn.Close();
            }
            return result;
        }
    }
}

<Page
    x:Class="TempPressure.MainPage"
    xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
    xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
    xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
    xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
    xmlns:lvc="using:LiveCharts.Uwp"
    mc:Ignorable="d"
    Background="{ThemeResource ApplicationPageBackgroundThemeBrush}">

    <Grid>
        <Grid.RowDefinitions>
            <RowDefinition />
            <RowDefinition />
            <RowDefinition />
        </Grid.RowDefinitions>
        <Grid.ColumnDefinitions>
            <ColumnDefinition />
            <ColumnDefinition />
            <ColumnDefinition />
        </Grid.ColumnDefinitions>

        <Button x:Name="btnCollectReadings" Width="250" Height="250" 
Click="BtnCollectReadings_Click" Grid.Column="0" Grid.Row="0">Collect 10 Readings</Button>
        <Button x:Name="btnRefreshReadings" Width="250" Height="250" Grid.Row="0" 
Grid.Column="1" Click="BtnRefreshReadings_Click">Refresh Readings</Button>
        <Button x:Name="btnDropTable" Width="250" Height="250" Grid.Row="0" Grid.Column="2" 
Click="BtnDropTable_Click">Drop Table</Button>
        <ListBox x:Name="lstReadings" Grid.ColumnSpan="3" Grid.Row="1" Grid.Column="0" 
ItemsSource="{Binding Readings}"  >
            <ListBox.ItemTemplate>
                <DataTemplate>
                    <Border>
                        <StackPanel Orientation="Vertical">
                            <TextBlock Text="{Binding DeviceName}"></TextBlock>
                            <StackPanel Orientation="Horizontal">
                                <TextBlock Text="Temperature (C): "></TextBlock>
                                <TextBlock Text="{Binding Temperature}"></TextBlock>
                            </StackPanel>
                            <StackPanel Orientation="Horizontal">
                                <TextBlock Text="Pressure (Pa): "></TextBlock>
                                <TextBlock Text="{Binding Pressure}"></TextBlock>
                            </StackPanel>
                            <StackPanel Orientation="Horizontal">
                                <TextBlock Text="Altitude (m): "></TextBlock>
                                <TextBlock Text="{Binding Altitude}"></TextBlock>
                            </StackPanel>
                            <StackPanel Orientation="Horizontal">
                                <TextBlock Text="Timestamp: "></TextBlock>
                                <TextBlock Text="{Binding ReadingTs}"></TextBlock>
                            </StackPanel>
                        </StackPanel>
                    </Border>
                </DataTemplate>
            </ListBox.ItemTemplate>
           
        </ListBox>
        <lvc:CartesianChart Series="{Binding Series}" Grid.ColumnSpan="3" Grid.Row="2" 
Grid.Column="0">
            <lvc:CartesianChart.AxisX>
                <lvc:Axis LabelFormatter="{Binding LabelFormatter}"></lvc:Axis>
            </lvc:CartesianChart.AxisX>
        </lvc:CartesianChart>
    </Grid>
</Page>

using LiveCharts;
using LiveCharts.Configurations;
using LiveCharts.Uwp;
using System;
using System.Collections.ObjectModel;
using System.Diagnostics;
using System.Threading.Tasks;
using Windows.UI.Xaml;
using Windows.UI.Xaml.Controls;
using Windows.UI.Xaml.Navigation;

namespace TempPressure
{
    /// <summary>
    /// Control Screen for reading and displaying temperature data
    /// </summary>
    public sealed partial class MainPage : Page
    {
        private BMP280 _bmp280;
        private ActianZenDataSource _ds;
        private string _deviceName; 
        public ObservableCollection<Reading> Readings { get; set; } 

        //chart items
        public SeriesCollection Series { get; set; }
        public Func<double, string> LabelFormatter { get; set; }

        public MainPage()
        {
            this.InitializeComponent();
           
        }

        //This method will be called by the application framework when the page is first loaded
        protected override async void OnNavigatedTo(NavigationEventArgs navArgs)
        {
            try
            {

                //initialize public properties
                //Create a new object for our barometric sensor class
                _bmp280 = new BMP280();
                //Initialize the sensor
                await _bmp280.Initialize();

                _ds = new ActianZenDataSource();
                _deviceName = "CPI3";
                Readings = new ObservableCollection<Reading>();
                                              
                //initialize series configuration and label formatting for the chart
                var chartConfig = Mappers.Xy<Reading>()
                    .X(model => (double)model.ReadingTs.Ticks)
                    .Y(model => model.Temperature);
                Series = new SeriesCollection(chartConfig);
                LabelFormatter = value => new System.DateTime((long)value).ToString("hh:mm:ss tt");

                this.DataContext = this;
            }
            catch(Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
        }

        private async void BtnCollectReadings_Click(object sender, RoutedEventArgs e)
        {
                try
                {

                    //Create variables to store the sensor data: temperature, pressure and 
altitude. 
                    //Initialize them to 0.
                    double temp = 0;
                    double pressure = 0;
                    double altitude = 0;

                    //Create a constant for pressure at sea level. 
                    //This is based on your local sea level pressure (Unit: Hectopascal)
                    //visit https://www.weather.gov/ and input zip code to obtain the barometer 
value
                    const double seaLevelPressure = 1013.5;

                    //Read 10 samples of the data at an interval of 1 second
                    for (int i = 0; i < 10; i++)
                    {
                        temp = await _bmp280.ReadTemperature();
                        pressure = await _bmp280.ReadPressure();
                        altitude = await _bmp280.ReadAltitude(seaLevelPressure);

                        //Write the values to your debug console
                        Debug.WriteLine("Temperature: " + temp.ToString() + " deg C");
                        Debug.WriteLine("Pressure: " + pressure.ToString() + " Pa");
                        Debug.WriteLine("Altitude: " + altitude.ToString() + " m");

                        //add the reading to the Actian table
                        _ds.AddReading(new Reading()
                        {
                            DeviceName = _deviceName,
                            Temperature = temp,
                            Pressure = pressure,
                            Altitude = altitude,
                            ReadingTs = DateTime.Now
                        });

                        await Task.Delay(1000);
                    }
            }
            catch (Exception ex)
            {
                Debug.WriteLine(ex.Message);
            }
        }

        private void BtnRefreshReadings_Click(object sender, RoutedEventArgs e)
        {

            //update list and chart with values retrieved from the Actian database

            Readings.Clear();
            Series.Clear();

            var chartValues = new ChartValues<Reading>();
            var readings =  _ds.GetReadings();
            readings.ForEach((read) => {
                Readings.Add(read);
                chartValues.Add(read);
            });
                        
            Series.Add(new LineSeries() { Values = chartValues });
        }

        private void BtnDropTable_Click(object sender, RoutedEventArgs e)
        {
            //clean up - remove readings table from the database
            _ds.DropTable();
        }
    }
    
}